-
- Downloads
Made checkpoint data in RDDs optional to further reduce serialized size.
Showing
- core/src/main/scala/spark/RDD.scala 11 additions, 8 deletionscore/src/main/scala/spark/RDD.scala
- core/src/main/scala/spark/SparkContext.scala 11 additions, 0 deletionscore/src/main/scala/spark/SparkContext.scala
- core/src/test/scala/spark/CheckpointSuite.scala 6 additions, 6 deletionscore/src/test/scala/spark/CheckpointSuite.scala
- streaming/src/main/scala/spark/streaming/DStream.scala 1 addition, 3 deletionsstreaming/src/main/scala/spark/streaming/DStream.scala
Loading
Please register or sign in to comment