-
- Downloads
[SPARK-7745] Change asserts to requires for user input checks in Spark Streaming
Assertions can be turned off. `require` throws an `IllegalArgumentException` which makes more sense when it's a user set variable. Author: Burak Yavuz <brkyvz@gmail.com> Closes #6271 from brkyvz/streaming-require and squashes the following commits: d249484 [Burak Yavuz] fix merge conflict 264adb8 [Burak Yavuz] addressed comments v1.0 6161350 [Burak Yavuz] fix tests 16aa766 [Burak Yavuz] changed more assertions to more meaningful errors afd923d [Burak Yavuz] changed some assertions to require
Showing
- streaming/src/main/scala/org/apache/spark/streaming/DStreamGraph.scala 2 additions, 2 deletions.../main/scala/org/apache/spark/streaming/DStreamGraph.scala
- streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala 6 additions, 5 deletions...n/scala/org/apache/spark/streaming/StreamingContext.scala
- streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonDStream.scala 2 additions, 2 deletions...org/apache/spark/streaming/api/python/PythonDStream.scala
- streaming/src/main/scala/org/apache/spark/streaming/dstream/DStream.scala 22 additions, 23 deletions...in/scala/org/apache/spark/streaming/dstream/DStream.scala
- streaming/src/main/scala/org/apache/spark/streaming/dstream/ReducedWindowedDStream.scala 2 additions, 2 deletions...ache/spark/streaming/dstream/ReducedWindowedDStream.scala
- streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceivedBlockTracker.scala 1 addition, 1 deletion...ache/spark/streaming/scheduler/ReceivedBlockTracker.scala
- streaming/src/test/scala/org/apache/spark/streaming/StreamingContextSuite.scala 3 additions, 3 deletions...la/org/apache/spark/streaming/StreamingContextSuite.scala
Loading
Please register or sign in to comment