-
- Downloads
Merge pull request #328 from rxin/spark-635
SPARK-635: Pass a TaskContext object to compute() interface and use that to close Hadoop input stream.
No related branches found
No related tags found
Showing
- core/src/main/scala/spark/CacheTracker.scala 15 additions, 14 deletionscore/src/main/scala/spark/CacheTracker.scala
- core/src/main/scala/spark/PairRDDFunctions.scala 8 additions, 7 deletionscore/src/main/scala/spark/PairRDDFunctions.scala
- core/src/main/scala/spark/ParallelCollection.scala 9 additions, 8 deletionscore/src/main/scala/spark/ParallelCollection.scala
- core/src/main/scala/spark/RDD.scala 4 additions, 4 deletionscore/src/main/scala/spark/RDD.scala
- core/src/main/scala/spark/TaskContext.scala 18 additions, 1 deletioncore/src/main/scala/spark/TaskContext.scala
- core/src/main/scala/spark/api/java/JavaRDDLike.scala 12 additions, 13 deletionscore/src/main/scala/spark/api/java/JavaRDDLike.scala
- core/src/main/scala/spark/rdd/BlockRDD.scala 11 additions, 14 deletionscore/src/main/scala/spark/rdd/BlockRDD.scala
- core/src/main/scala/spark/rdd/CartesianRDD.scala 8 additions, 9 deletionscore/src/main/scala/spark/rdd/CartesianRDD.scala
- core/src/main/scala/spark/rdd/CoGroupedRDD.scala 12 additions, 18 deletionscore/src/main/scala/spark/rdd/CoGroupedRDD.scala
- core/src/main/scala/spark/rdd/CoalescedRDD.scala 4 additions, 5 deletionscore/src/main/scala/spark/rdd/CoalescedRDD.scala
- core/src/main/scala/spark/rdd/FilteredRDD.scala 3 additions, 4 deletionscore/src/main/scala/spark/rdd/FilteredRDD.scala
- core/src/main/scala/spark/rdd/FlatMappedRDD.scala 5 additions, 5 deletionscore/src/main/scala/spark/rdd/FlatMappedRDD.scala
- core/src/main/scala/spark/rdd/GlommedRDD.scala 4 additions, 4 deletionscore/src/main/scala/spark/rdd/GlommedRDD.scala
- core/src/main/scala/spark/rdd/HadoopRDD.scala 11 additions, 11 deletionscore/src/main/scala/spark/rdd/HadoopRDD.scala
- core/src/main/scala/spark/rdd/MapPartitionsRDD.scala 4 additions, 5 deletionscore/src/main/scala/spark/rdd/MapPartitionsRDD.scala
- core/src/main/scala/spark/rdd/MapPartitionsWithSplitRDD.scala 3 additions, 4 deletions.../src/main/scala/spark/rdd/MapPartitionsWithSplitRDD.scala
- core/src/main/scala/spark/rdd/MappedRDD.scala 3 additions, 5 deletionscore/src/main/scala/spark/rdd/MappedRDD.scala
- core/src/main/scala/spark/rdd/NewHadoopRDD.scala 16 additions, 18 deletionscore/src/main/scala/spark/rdd/NewHadoopRDD.scala
- core/src/main/scala/spark/rdd/PipedRDD.scala 4 additions, 7 deletionscore/src/main/scala/spark/rdd/PipedRDD.scala
- core/src/main/scala/spark/rdd/SampledRDD.scala 7 additions, 8 deletionscore/src/main/scala/spark/rdd/SampledRDD.scala
Loading
Please register or sign in to comment