-
- Downloads
[SPARK-5379][Streaming] Add awaitTerminationOrTimeout
Added `awaitTerminationOrTimeout` to return if the waiting time elapsed: * `true` if it's stopped. * `false` if the waiting time elapsed before returning from the method. * throw the reported error if it's thrown during the execution. Also deprecated `awaitTermination(timeout: Long)`. Author: zsxwing <zsxwing@gmail.com> Closes #4171 from zsxwing/SPARK-5379 and squashes the following commits: c9e660b [zsxwing] Add a unit test for awaitTerminationOrTimeout 8a89f92 [zsxwing] Add awaitTerminationOrTimeout to python cdc820b [zsxwing] Add awaitTerminationOrTimeout
Showing
- python/pyspark/streaming/context.py 9 additions, 0 deletionspython/pyspark/streaming/context.py
- streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala 13 additions, 0 deletions...n/scala/org/apache/spark/streaming/StreamingContext.scala
- streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaStreamingContext.scala 13 additions, 0 deletions...pache/spark/streaming/api/java/JavaStreamingContext.scala
- streaming/src/test/scala/org/apache/spark/streaming/StreamingContextSuite.scala 24 additions, 0 deletions...la/org/apache/spark/streaming/StreamingContextSuite.scala
Loading
Please register or sign in to comment