-
- Downloads
Changed StreamingContext.stopForWait to awaitTermination.
Showing
- streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala 3 additions, 3 deletions...n/scala/org/apache/spark/streaming/StreamingContext.scala
- streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaStreamingContext.scala 3 additions, 3 deletions...pache/spark/streaming/api/java/JavaStreamingContext.scala
- streaming/src/test/scala/org/apache/spark/streaming/StreamingContextSuite.scala 8 additions, 8 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