aboutsummaryrefslogtreecommitdiff
path: root/core/src/main
diff options
context:
space:
mode:
authorDenny <dennybritz@gmail.com>2012-10-02 19:04:23 -0700
committerDenny <dennybritz@gmail.com>2012-10-02 19:04:23 -0700
commitb7a913e1facae6ee24b63bd1e6b3379956d1c8c4 (patch)
tree5be3ac70ef934069d1506f0e2c6a225d92dd3412 /core/src/main
parent4d9f4b01af056b09befe860822729e0d60a4bfe7 (diff)
downloadspark-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.scala10
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) = {