-
- Downloads
Merge branch 'dev-checkpoint' of github.com:radlab/spark into dev-merge
Conflicts: core/src/main/scala/spark/ParallelCollection.scala core/src/main/scala/spark/RDD.scala core/src/main/scala/spark/rdd/BlockRDD.scala core/src/main/scala/spark/rdd/CartesianRDD.scala core/src/main/scala/spark/rdd/CoGroupedRDD.scala core/src/main/scala/spark/rdd/CoalescedRDD.scala core/src/main/scala/spark/rdd/FilteredRDD.scala core/src/main/scala/spark/rdd/FlatMappedRDD.scala core/src/main/scala/spark/rdd/GlommedRDD.scala core/src/main/scala/spark/rdd/HadoopRDD.scala core/src/main/scala/spark/rdd/MapPartitionsRDD.scala core/src/main/scala/spark/rdd/MapPartitionsWithSplitRDD.scala core/src/main/scala/spark/rdd/MappedRDD.scala core/src/main/scala/spark/rdd/PipedRDD.scala core/src/main/scala/spark/rdd/SampledRDD.scala core/src/main/scala/spark/rdd/ShuffledRDD.scala core/src/main/scala/spark/rdd/UnionRDD.scala core/src/main/scala/spark/scheduler/ResultTask.scala core/src/test/scala/spark/CheckpointSuite.scala
Showing
- core/src/main/scala/spark/PairRDDFunctions.scala 6 additions, 7 deletionscore/src/main/scala/spark/PairRDDFunctions.scala
- core/src/main/scala/spark/ParallelCollection.scala 10 additions, 6 deletionscore/src/main/scala/spark/ParallelCollection.scala
- core/src/main/scala/spark/RDD.scala 109 additions, 130 deletionscore/src/main/scala/spark/RDD.scala
- core/src/main/scala/spark/RDDCheckpointData.scala 97 additions, 0 deletionscore/src/main/scala/spark/RDDCheckpointData.scala
- core/src/main/scala/spark/SparkContext.scala 10 additions, 13 deletionscore/src/main/scala/spark/SparkContext.scala
- core/src/main/scala/spark/rdd/BlockRDD.scala 7 additions, 10 deletionscore/src/main/scala/spark/rdd/BlockRDD.scala
- core/src/main/scala/spark/rdd/CartesianRDD.scala 27 additions, 16 deletionscore/src/main/scala/spark/rdd/CartesianRDD.scala
- core/src/main/scala/spark/rdd/CheckpointRDD.scala 124 additions, 0 deletionscore/src/main/scala/spark/rdd/CheckpointRDD.scala
- core/src/main/scala/spark/rdd/CoGroupedRDD.scala 20 additions, 20 deletionscore/src/main/scala/spark/rdd/CoGroupedRDD.scala
- core/src/main/scala/spark/rdd/CoalescedRDD.scala 22 additions, 11 deletionscore/src/main/scala/spark/rdd/CoalescedRDD.scala
- core/src/main/scala/spark/rdd/FilteredRDD.scala 7 additions, 7 deletionscore/src/main/scala/spark/rdd/FilteredRDD.scala
- core/src/main/scala/spark/rdd/FlatMappedRDD.scala 4 additions, 5 deletionscore/src/main/scala/spark/rdd/FlatMappedRDD.scala
- core/src/main/scala/spark/rdd/GlommedRDD.scala 5 additions, 6 deletionscore/src/main/scala/spark/rdd/GlommedRDD.scala
- core/src/main/scala/spark/rdd/HadoopRDD.scala 7 additions, 6 deletionscore/src/main/scala/spark/rdd/HadoopRDD.scala
- core/src/main/scala/spark/rdd/MapPartitionsRDD.scala 6 additions, 10 deletionscore/src/main/scala/spark/rdd/MapPartitionsRDD.scala
- core/src/main/scala/spark/rdd/MapPartitionsWithSplitRDD.scala 7 additions, 7 deletions.../src/main/scala/spark/rdd/MapPartitionsWithSplitRDD.scala
- core/src/main/scala/spark/rdd/MappedRDD.scala 4 additions, 6 deletionscore/src/main/scala/spark/rdd/MappedRDD.scala
- core/src/main/scala/spark/rdd/NewHadoopRDD.scala 2 additions, 4 deletionscore/src/main/scala/spark/rdd/NewHadoopRDD.scala
- core/src/main/scala/spark/rdd/PipedRDD.scala 5 additions, 6 deletionscore/src/main/scala/spark/rdd/PipedRDD.scala
- core/src/main/scala/spark/rdd/SampledRDD.scala 10 additions, 7 deletionscore/src/main/scala/spark/rdd/SampledRDD.scala
Loading
Please register or sign in to comment