-
- Downloads
[SPARK-7237] [SPARK-7741] [CORE] [STREAMING] Clean more closures that need cleaning
SPARK-7741 is the equivalent of SPARK-7237 in streaming. This is an alternative to #6268. Author: Andrew Or <andrew@databricks.com> Closes #6269 from andrewor14/clean-moar and squashes the following commits: c51c9ab [Andrew Or] Add periods (trivial) 6c686ac [Andrew Or] Merge branch 'master' of github.com:apache/spark into clean-moar 79a435b [Andrew Or] Fix tests d18c9f9 [Andrew Or] Merge branch 'master' of github.com:apache/spark into clean-moar 65ef07b [Andrew Or] Fix tests? 4b487a3 [Andrew Or] Add tests for closures passed to DStream operations 328139b [Andrew Or] Do not forget foreachRDD 5431f61 [Andrew Or] Clean streaming closures 72b7b73 [Andrew Or] Clean core closures
Showing
- core/src/main/scala/org/apache/spark/SparkContext.scala 2 additions, 2 deletionscore/src/main/scala/org/apache/spark/SparkContext.scala
- core/src/main/scala/org/apache/spark/rdd/PairRDDFunctions.scala 3 additions, 2 deletions...rc/main/scala/org/apache/spark/rdd/PairRDDFunctions.scala
- core/src/test/scala/org/apache/spark/util/ClosureCleanerSuite.scala 4 additions, 0 deletions...est/scala/org/apache/spark/util/ClosureCleanerSuite.scala
- streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala 1 addition, 1 deletion...n/scala/org/apache/spark/streaming/StreamingContext.scala
- streaming/src/main/scala/org/apache/spark/streaming/dstream/DStream.scala 3 additions, 2 deletions...in/scala/org/apache/spark/streaming/dstream/DStream.scala
- streaming/src/main/scala/org/apache/spark/streaming/dstream/PairDStreamFunctions.scala 20 additions, 10 deletions...apache/spark/streaming/dstream/PairDStreamFunctions.scala
- streaming/src/test/scala/org/apache/spark/streaming/DStreamClosureSuite.scala 196 additions, 0 deletions...cala/org/apache/spark/streaming/DStreamClosureSuite.scala
- streaming/src/test/scala/org/apache/spark/streaming/DStreamScopeSuite.scala 2 additions, 20 deletions.../scala/org/apache/spark/streaming/DStreamScopeSuite.scala
- streaming/src/test/scala/org/apache/spark/streaming/TestSuiteBase.scala 18 additions, 0 deletions...test/scala/org/apache/spark/streaming/TestSuiteBase.scala
Loading
Please register or sign in to comment