-
- Downloads
Merge pull request #847 from rxin/rdd
Allow subclasses of Product2 in all key-value related classes
No related branches found
No related tags found
Showing
- core/src/main/scala/spark/Aggregator.scala 9 additions, 9 deletionscore/src/main/scala/spark/Aggregator.scala
- core/src/main/scala/spark/BlockStoreShuffleFetcher.scala 6 additions, 5 deletionscore/src/main/scala/spark/BlockStoreShuffleFetcher.scala
- core/src/main/scala/spark/Dependency.scala 2 additions, 2 deletionscore/src/main/scala/spark/Dependency.scala
- core/src/main/scala/spark/PairRDDFunctions.scala 40 additions, 96 deletionscore/src/main/scala/spark/PairRDDFunctions.scala
- core/src/main/scala/spark/Partitioner.scala 1 addition, 1 deletioncore/src/main/scala/spark/Partitioner.scala
- core/src/main/scala/spark/RDD.scala 7 additions, 5 deletionscore/src/main/scala/spark/RDD.scala
- core/src/main/scala/spark/ShuffleFetcher.scala 3 additions, 2 deletionscore/src/main/scala/spark/ShuffleFetcher.scala
- core/src/main/scala/spark/SparkContext.scala 9 additions, 15 deletionscore/src/main/scala/spark/SparkContext.scala
- core/src/main/scala/spark/api/java/JavaPairRDD.scala 8 additions, 7 deletionscore/src/main/scala/spark/api/java/JavaPairRDD.scala
- core/src/main/scala/spark/rdd/CoGroupedRDD.scala 9 additions, 9 deletionscore/src/main/scala/spark/rdd/CoGroupedRDD.scala
- core/src/main/scala/spark/rdd/FlatMappedValuesRDD.scala 36 additions, 0 deletionscore/src/main/scala/spark/rdd/FlatMappedValuesRDD.scala
- core/src/main/scala/spark/rdd/MappedValuesRDD.scala 34 additions, 0 deletionscore/src/main/scala/spark/rdd/MappedValuesRDD.scala
- core/src/main/scala/spark/rdd/OrderedRDDFunctions.scala 51 additions, 0 deletionscore/src/main/scala/spark/rdd/OrderedRDDFunctions.scala
- core/src/main/scala/spark/rdd/ShuffledRDD.scala 7 additions, 9 deletionscore/src/main/scala/spark/rdd/ShuffledRDD.scala
- core/src/main/scala/spark/rdd/SubtractedRDD.scala 9 additions, 11 deletionscore/src/main/scala/spark/rdd/SubtractedRDD.scala
- core/src/main/scala/spark/scheduler/ShuffleMapTask.scala 1 addition, 1 deletioncore/src/main/scala/spark/scheduler/ShuffleMapTask.scala
- core/src/main/scala/spark/util/MutablePair.scala 36 additions, 0 deletionscore/src/main/scala/spark/util/MutablePair.scala
- core/src/test/scala/spark/CheckpointSuite.scala 1 addition, 1 deletioncore/src/test/scala/spark/CheckpointSuite.scala
- core/src/test/scala/spark/PairRDDFunctionsSuite.scala 1 addition, 6 deletionscore/src/test/scala/spark/PairRDDFunctionsSuite.scala
- core/src/test/scala/spark/RDDSuite.scala 1 addition, 1 deletioncore/src/test/scala/spark/RDDSuite.scala
Loading
Please register or sign in to comment