diff options
| author | Reynold Xin <rxin@databricks.com> | 2015-05-31 01:37:56 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2015-05-31 01:37:56 -0700 |
| commit | 4b5f12bac939a2f47a3a61365b5325d849b7b51f (patch) | |
| tree | 9194cea6c59b27cea490339597dd3faea8a18988 /graphx | |
| parent | 63a50be13d32b9e5f3aad8d1a6ba5362f17a252f (diff) | |
| download | spark-4b5f12bac939a2f47a3a61365b5325d849b7b51f.tar.gz spark-4b5f12bac939a2f47a3a61365b5325d849b7b51f.tar.bz2 spark-4b5f12bac939a2f47a3a61365b5325d849b7b51f.zip | |
[SPARK-7979] Enforce structural type checker.
Author: Reynold Xin <rxin@databricks.com>
Closes #6536 from rxin/structural-type-checker and squashes the following commits:
f833151 [Reynold Xin] Fixed compilation.
633f9a1 [Reynold Xin] Fixed typo.
d1fa804 [Reynold Xin] [SPARK-7979] Enforce structural type checker.
Diffstat (limited to 'graphx')
| -rw-r--r-- | graphx/src/main/scala/org/apache/spark/graphx/EdgeRDD.scala | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/graphx/src/main/scala/org/apache/spark/graphx/EdgeRDD.scala b/graphx/src/main/scala/org/apache/spark/graphx/EdgeRDD.scala index cc70b396a8..4611a3ace2 100644 --- a/graphx/src/main/scala/org/apache/spark/graphx/EdgeRDD.scala +++ b/graphx/src/main/scala/org/apache/spark/graphx/EdgeRDD.scala @@ -41,14 +41,16 @@ abstract class EdgeRDD[ED]( @transient sc: SparkContext, @transient deps: Seq[Dependency[_]]) extends RDD[Edge[ED]](sc, deps) { + // scalastyle:off structural.type private[graphx] def partitionsRDD: RDD[(PartitionID, EdgePartition[ED, VD])] forSome { type VD } + // scalastyle:on structural.type override protected def getPartitions: Array[Partition] = partitionsRDD.partitions override def compute(part: Partition, context: TaskContext): Iterator[Edge[ED]] = { val p = firstParent[(PartitionID, EdgePartition[ED, _])].iterator(part, context) if (p.hasNext) { - p.next._2.iterator.map(_.copy()) + p.next()._2.iterator.map(_.copy()) } else { Iterator.empty } |