-
- Downloads
Made PairRDDFunctions taking only Tuple2, but made the rest of the shuffle...
Made PairRDDFunctions taking only Tuple2, but made the rest of the shuffle code path working with general Product2.
Showing
- core/src/main/scala/spark/Aggregator.scala 5 additions, 5 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/PairRDDFunctions.scala 24 additions, 26 deletionscore/src/main/scala/spark/PairRDDFunctions.scala
- core/src/main/scala/spark/RDD.scala 4 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 1 addition, 1 deletioncore/src/main/scala/spark/SparkContext.scala
- core/src/main/scala/spark/api/java/JavaPairRDD.scala 1 addition, 1 deletioncore/src/main/scala/spark/api/java/JavaPairRDD.scala
- core/src/main/scala/spark/rdd/CoGroupedRDD.scala 6 additions, 6 deletionscore/src/main/scala/spark/rdd/CoGroupedRDD.scala
- core/src/main/scala/spark/rdd/FlatMappedValuesRDD.scala 1 addition, 1 deletioncore/src/main/scala/spark/rdd/FlatMappedValuesRDD.scala
- core/src/main/scala/spark/rdd/MappedValuesRDD.scala 1 addition, 1 deletioncore/src/main/scala/spark/rdd/MappedValuesRDD.scala
- core/src/main/scala/spark/rdd/OrderedRDDFunctions.scala 7 additions, 7 deletionscore/src/main/scala/spark/rdd/OrderedRDDFunctions.scala
- core/src/main/scala/spark/rdd/ShuffledRDD.scala 6 additions, 6 deletionscore/src/main/scala/spark/rdd/ShuffledRDD.scala
- core/src/main/scala/spark/rdd/SubtractedRDD.scala 6 additions, 8 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 34 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
- core/src/test/scala/spark/ShuffleSuite.scala 23 additions, 8 deletionscore/src/test/scala/spark/ShuffleSuite.scala
- tools/src/main/scala/spark/tools/JavaAPICompletenessChecker.scala 1 addition, 1 deletion...c/main/scala/spark/tools/JavaAPICompletenessChecker.scala
Loading
Please register or sign in to comment