-
- Downloads
Converted JobScheduler to use actors for event handling. Changed...
Converted JobScheduler to use actors for event handling. Changed protected[streaming] to private[streaming] in StreamingContext and DStream. Added waitForStop to StreamingContext, and StreamingContextSuite.
Showing
- core/src/main/scala/org/apache/spark/util/MetadataCleaner.scala 1 addition, 1 deletion...rc/main/scala/org/apache/spark/util/MetadataCleaner.scala
- streaming/src/main/scala/org/apache/spark/streaming/Checkpoint.scala 1 addition, 1 deletion...rc/main/scala/org/apache/spark/streaming/Checkpoint.scala
- streaming/src/main/scala/org/apache/spark/streaming/ContextWaiter.scala 28 additions, 0 deletions...main/scala/org/apache/spark/streaming/ContextWaiter.scala
- streaming/src/main/scala/org/apache/spark/streaming/DStream.scala 28 additions, 28 deletions...g/src/main/scala/org/apache/spark/streaming/DStream.scala
- streaming/src/main/scala/org/apache/spark/streaming/DStreamGraph.scala 7 additions, 1 deletion.../main/scala/org/apache/spark/streaming/DStreamGraph.scala
- streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala 49 additions, 62 deletions...n/scala/org/apache/spark/streaming/StreamingContext.scala
- streaming/src/main/scala/org/apache/spark/streaming/dstream/InputDStream.scala 1 addition, 1 deletion...ala/org/apache/spark/streaming/dstream/InputDStream.scala
- streaming/src/main/scala/org/apache/spark/streaming/dstream/NetworkInputDStream.scala 1 addition, 1 deletion.../apache/spark/streaming/dstream/NetworkInputDStream.scala
- streaming/src/main/scala/org/apache/spark/streaming/scheduler/Job.scala 4 additions, 5 deletions...main/scala/org/apache/spark/streaming/scheduler/Job.scala
- streaming/src/main/scala/org/apache/spark/streaming/scheduler/JobGenerator.scala 23 additions, 17 deletions...a/org/apache/spark/streaming/scheduler/JobGenerator.scala
- streaming/src/main/scala/org/apache/spark/streaming/scheduler/JobScheduler.scala 90 additions, 44 deletions...a/org/apache/spark/streaming/scheduler/JobScheduler.scala
- streaming/src/main/scala/org/apache/spark/streaming/scheduler/JobSet.scala 9 additions, 9 deletions...n/scala/org/apache/spark/streaming/scheduler/JobSet.scala
- streaming/src/main/scala/org/apache/spark/streaming/scheduler/NetworkInputTracker.scala 11 additions, 9 deletions...pache/spark/streaming/scheduler/NetworkInputTracker.scala
- streaming/src/test/scala/org/apache/spark/streaming/BasicOperationsSuite.scala 1 addition, 5 deletions...ala/org/apache/spark/streaming/BasicOperationsSuite.scala
- streaming/src/test/scala/org/apache/spark/streaming/CheckpointSuite.scala 22 additions, 0 deletions...st/scala/org/apache/spark/streaming/CheckpointSuite.scala
- streaming/src/test/scala/org/apache/spark/streaming/StreamingContextSuite.scala 208 additions, 0 deletions...la/org/apache/spark/streaming/StreamingContextSuite.scala
- streaming/src/test/scala/org/apache/spark/streaming/TestSuiteBase.scala 1 addition, 1 deletion...test/scala/org/apache/spark/streaming/TestSuiteBase.scala
Loading
Please register or sign in to comment