-
- Downloads
Modified checkpoing file clearing policy.
Showing
- streaming/src/main/scala/org/apache/spark/streaming/Checkpoint.scala 5 additions, 2 deletions...rc/main/scala/org/apache/spark/streaming/Checkpoint.scala
- streaming/src/main/scala/org/apache/spark/streaming/DStream.scala 10 additions, 5 deletions...g/src/main/scala/org/apache/spark/streaming/DStream.scala
- streaming/src/main/scala/org/apache/spark/streaming/DStreamCheckpointData.scala 44 additions, 19 deletions...la/org/apache/spark/streaming/DStreamCheckpointData.scala
- streaming/src/main/scala/org/apache/spark/streaming/DStreamGraph.scala 19 additions, 11 deletions.../main/scala/org/apache/spark/streaming/DStreamGraph.scala
- streaming/src/main/scala/org/apache/spark/streaming/dstream/FileInputDStream.scala 4 additions, 4 deletions...org/apache/spark/streaming/dstream/FileInputDStream.scala
- streaming/src/main/scala/org/apache/spark/streaming/scheduler/JobGenerator.scala 17 additions, 6 deletions...a/org/apache/spark/streaming/scheduler/JobGenerator.scala
- streaming/src/test/scala/org/apache/spark/streaming/CheckpointSuite.scala 5 additions, 5 deletions...st/scala/org/apache/spark/streaming/CheckpointSuite.scala
Loading
Please register or sign in to comment