-
- Downloads
[SPARK-18694][SS] Add StreamingQuery.explain and exception to Python and fix...
[SPARK-18694][SS] Add StreamingQuery.explain and exception to Python and fix StreamingQueryException ## What changes were proposed in this pull request? - Add StreamingQuery.explain and exception to Python. - Fix StreamingQueryException to not expose `OffsetSeq`. ## How was this patch tested? Jenkins Author: Shixiong Zhu <shixiong@databricks.com> Closes #16125 from zsxwing/py-streaming-explain.
Showing
- project/MimaExcludes.scala 8 additions, 1 deletionproject/MimaExcludes.scala
- python/pyspark/sql/streaming.py 40 additions, 0 deletionspython/pyspark/sql/streaming.py
- python/pyspark/sql/tests.py 29 additions, 0 deletionspython/pyspark/sql/tests.py
- sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala 3 additions, 2 deletions...pache/spark/sql/execution/streaming/StreamExecution.scala
- sql/core/src/main/scala/org/apache/spark/sql/streaming/StreamingQueryException.scala 26 additions, 16 deletions.../apache/spark/sql/streaming/StreamingQueryException.scala
- sql/core/src/main/scala/org/apache/spark/sql/streaming/progress.scala 7 additions, 0 deletions.../main/scala/org/apache/spark/sql/streaming/progress.scala
- sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamTest.scala 0 additions, 2 deletions...est/scala/org/apache/spark/sql/streaming/StreamTest.scala
- sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamingQuerySuite.scala 6 additions, 4 deletions.../org/apache/spark/sql/streaming/StreamingQuerySuite.scala
Loading
Please register or sign in to comment