diff options
| author | Josh Rosen <joshrosen@eecs.berkeley.edu> | 2012-10-04 11:12:57 -0700 |
|---|---|---|
| committer | Josh Rosen <joshrosen@eecs.berkeley.edu> | 2012-10-07 00:03:55 -0700 |
| commit | 3f2571fe9858c020544be2248ec1fa641f66ca3f (patch) | |
| tree | 161303e85458f3a91478283c527ff4cce9de23b3 /core/src | |
| parent | b2fc3dd902d12ab936cd0f51431868010e521e28 (diff) | |
| download | spark-3f2571fe9858c020544be2248ec1fa641f66ca3f.tar.gz spark-3f2571fe9858c020544be2248ec1fa641f66ca3f.tar.bz2 spark-3f2571fe9858c020544be2248ec1fa641f66ca3f.zip | |
Remove unused isShuffle field from Dependency.
Diffstat (limited to 'core/src')
| -rw-r--r-- | core/src/main/scala/spark/Dependency.scala | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/core/src/main/scala/spark/Dependency.scala b/core/src/main/scala/spark/Dependency.scala index c0ff94acc6..979da9151f 100644 --- a/core/src/main/scala/spark/Dependency.scala +++ b/core/src/main/scala/spark/Dependency.scala @@ -1,8 +1,8 @@ package spark -abstract class Dependency[T](val rdd: RDD[T], val isShuffle: Boolean) extends Serializable +abstract class Dependency[T](val rdd: RDD[T]) extends Serializable -abstract class NarrowDependency[T](rdd: RDD[T]) extends Dependency(rdd, false) { +abstract class NarrowDependency[T](rdd: RDD[T]) extends Dependency(rdd) { def getParents(outputPartition: Int): Seq[Int] } @@ -11,7 +11,7 @@ class ShuffleDependency[K, V, C]( @transient rdd: RDD[(K, V)], val aggregator: Aggregator[K, V, C], val partitioner: Partitioner) - extends Dependency(rdd, true) + extends Dependency(rdd) class OneToOneDependency[T](rdd: RDD[T]) extends NarrowDependency[T](rdd) { override def getParents(partitionId: Int) = List(partitionId) |