diff options
author | Denny <dennybritz@gmail.com> | 2012-10-02 19:04:23 -0700 |
---|---|---|
committer | Denny <dennybritz@gmail.com> | 2012-10-02 19:04:23 -0700 |
commit | b7a913e1facae6ee24b63bd1e6b3379956d1c8c4 (patch) | |
tree | 5be3ac70ef934069d1506f0e2c6a225d92dd3412 /core/src/main | |
parent | 4d9f4b01af056b09befe860822729e0d60a4bfe7 (diff) | |
download | spark-b7a913e1facae6ee24b63bd1e6b3379956d1c8c4.tar.gz spark-b7a913e1facae6ee24b63bd1e6b3379956d1c8c4.tar.bz2 spark-b7a913e1facae6ee24b63bd1e6b3379956d1c8c4.zip |
Make dependency classes public - used by spark
Diffstat (limited to 'core/src/main')
-rw-r--r-- | core/src/main/scala/spark/Dependency.scala | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/core/src/main/scala/spark/Dependency.scala b/core/src/main/scala/spark/Dependency.scala index a478710f04..c0ff94acc6 100644 --- a/core/src/main/scala/spark/Dependency.scala +++ b/core/src/main/scala/spark/Dependency.scala @@ -1,23 +1,23 @@ package spark -private[spark] abstract class Dependency[T](val rdd: RDD[T], val isShuffle: Boolean) extends Serializable +abstract class Dependency[T](val rdd: RDD[T], val isShuffle: Boolean) extends Serializable -private[spark] abstract class NarrowDependency[T](rdd: RDD[T]) extends Dependency(rdd, false) { +abstract class NarrowDependency[T](rdd: RDD[T]) extends Dependency(rdd, false) { def getParents(outputPartition: Int): Seq[Int] } -private[spark] class ShuffleDependency[K, V, C]( +class ShuffleDependency[K, V, C]( val shuffleId: Int, @transient rdd: RDD[(K, V)], val aggregator: Aggregator[K, V, C], val partitioner: Partitioner) extends Dependency(rdd, true) -private[spark] class OneToOneDependency[T](rdd: RDD[T]) extends NarrowDependency[T](rdd) { +class OneToOneDependency[T](rdd: RDD[T]) extends NarrowDependency[T](rdd) { override def getParents(partitionId: Int) = List(partitionId) } -private[spark] class RangeDependency[T](rdd: RDD[T], inStart: Int, outStart: Int, length: Int) +class RangeDependency[T](rdd: RDD[T], inStart: Int, outStart: Int, length: Int) extends NarrowDependency[T](rdd) { override def getParents(partitionId: Int) = { |