-
- Downloads
SPARK-3874: Provide stable TaskContext API
This is a small number of clean-up changes on top of #2782. Closes #2782. Author: Prashant Sharma <prashant.s@imaginea.com> Author: Patrick Wendell <pwendell@gmail.com> Closes #2803 from pwendell/pr-2782 and squashes the following commits: 56d5b7a [Patrick Wendell] Minor clean-up 44089ec [Patrick Wendell] Clean-up the TaskContext API. ed551ce [Prashant Sharma] Fixed a typo df261d0 [Prashant Sharma] Josh's suggestion facf3b1 [Prashant Sharma] Fixed the mima issue. 7ecc2fe [Prashant Sharma] CR, Moved implementations to TaskContextImpl bbd9e05 [Prashant Sharma] adding missed out files to git. ef633f5 [Prashant Sharma] SPARK-3874, Provide stable TaskContext API
Showing
- core/src/main/java/org/apache/spark/TaskContext.java 32 additions, 193 deletionscore/src/main/java/org/apache/spark/TaskContext.java
- core/src/main/scala/org/apache/spark/TaskContextHelper.scala 29 additions, 0 deletionscore/src/main/scala/org/apache/spark/TaskContextHelper.scala
- core/src/main/scala/org/apache/spark/TaskContextImpl.scala 91 additions, 0 deletionscore/src/main/scala/org/apache/spark/TaskContextImpl.scala
- core/src/main/scala/org/apache/spark/rdd/HadoopRDD.scala 1 addition, 1 deletioncore/src/main/scala/org/apache/spark/rdd/HadoopRDD.scala
- core/src/main/scala/org/apache/spark/rdd/PairRDDFunctions.scala 4 additions, 4 deletions...rc/main/scala/org/apache/spark/rdd/PairRDDFunctions.scala
- core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala 3 additions, 3 deletions.../main/scala/org/apache/spark/scheduler/DAGScheduler.scala
- core/src/main/scala/org/apache/spark/scheduler/Task.scala 5 additions, 5 deletionscore/src/main/scala/org/apache/spark/scheduler/Task.scala
- core/src/test/java/org/apache/spark/JavaAPISuite.java 1 addition, 1 deletioncore/src/test/java/org/apache/spark/JavaAPISuite.java
- core/src/test/java/org/apache/spark/util/JavaTaskCompletionListenerImpl.java 2 additions, 2 deletions...org/apache/spark/util/JavaTaskCompletionListenerImpl.java
- core/src/test/scala/org/apache/spark/CacheManagerSuite.scala 4 additions, 4 deletionscore/src/test/scala/org/apache/spark/CacheManagerSuite.scala
- core/src/test/scala/org/apache/spark/rdd/PipedRDDSuite.scala 1 addition, 1 deletioncore/src/test/scala/org/apache/spark/rdd/PipedRDDSuite.scala
- core/src/test/scala/org/apache/spark/scheduler/TaskContextSuite.scala 1 addition, 1 deletion...t/scala/org/apache/spark/scheduler/TaskContextSuite.scala
- core/src/test/scala/org/apache/spark/storage/ShuffleBlockFetcherIteratorSuite.scala 4 additions, 4 deletions...ache/spark/storage/ShuffleBlockFetcherIteratorSuite.scala
- project/MimaBuild.scala 1 addition, 1 deletionproject/MimaBuild.scala
- project/MimaExcludes.scala 5 additions, 1 deletionproject/MimaExcludes.scala
- sql/core/src/main/scala/org/apache/spark/sql/parquet/ParquetTableOperations.scala 2 additions, 2 deletions...org/apache/spark/sql/parquet/ParquetTableOperations.scala
Loading
Please register or sign in to comment