-
- Downloads
[SPARK-15686][SQL] Move user-facing streaming classes into sql.streaming
## What changes were proposed in this pull request? This patch moves all user-facing structured streaming classes into sql.streaming. As part of this, I also added some since version annotation to methods and classes that don't have them. ## How was this patch tested? Updated tests to reflect the moves. Author: Reynold Xin <rxin@databricks.com> Closes #13429 from rxin/SPARK-15686.
Showing
- python/pyspark/sql/streaming.py 2 additions, 1 deletionpython/pyspark/sql/streaming.py
- python/pyspark/sql/utils.py 1 addition, 1 deletionpython/pyspark/sql/utils.py
- sql/catalyst/src/main/java/org/apache/spark/sql/streaming/OutputMode.java 2 additions, 1 deletion.../main/java/org/apache/spark/sql/streaming/OutputMode.java
- sql/catalyst/src/main/scala/org/apache/spark/sql/InternalOutputModes.scala 2 additions, 0 deletions...main/scala/org/apache/spark/sql/InternalOutputModes.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/UnsupportedOperationChecker.scala 2 additions, 1 deletion...k/sql/catalyst/analysis/UnsupportedOperationChecker.scala
- sql/catalyst/src/test/java/org/apache/spark/sql/streaming/JavaOutputModeSuite.java 1 addition, 1 deletion...a/org/apache/spark/sql/streaming/JavaOutputModeSuite.java
- sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/analysis/UnsupportedOperationsSuite.scala 2 additions, 1 deletion...rk/sql/catalyst/analysis/UnsupportedOperationsSuite.scala
- sql/core/src/main/scala/org/apache/spark/sql/DataFrameWriter.scala 1 addition, 0 deletions...src/main/scala/org/apache/spark/sql/DataFrameWriter.scala
- sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala 1 addition, 0 deletionssql/core/src/main/scala/org/apache/spark/sql/Dataset.scala
- sql/core/src/main/scala/org/apache/spark/sql/SQLContext.scala 2 additions, 4 deletions...core/src/main/scala/org/apache/spark/sql/SQLContext.scala
- sql/core/src/main/scala/org/apache/spark/sql/SparkSession.scala 4 additions, 3 deletions...re/src/main/scala/org/apache/spark/sql/SparkSession.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/SparkStrategies.scala 2 additions, 1 deletion...cala/org/apache/spark/sql/execution/SparkStrategies.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/DataSource.scala 1 addition, 0 deletions...g/apache/spark/sql/execution/datasources/DataSource.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/ContinuousQueryListenerBus.scala 7 additions, 4 deletions.../sql/execution/streaming/ContinuousQueryListenerBus.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/IncrementalExecution.scala 2 additions, 1 deletion.../spark/sql/execution/streaming/IncrementalExecution.scala
- 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/execution/streaming/TriggerExecutor.scala 1 addition, 1 deletion...pache/spark/sql/execution/streaming/TriggerExecutor.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/console.scala 2 additions, 1 deletion...la/org/apache/spark/sql/execution/streaming/console.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/memory.scala 1 addition, 0 deletions...ala/org/apache/spark/sql/execution/streaming/memory.scala
- sql/core/src/main/scala/org/apache/spark/sql/internal/SessionState.scala 2 additions, 1 deletion...in/scala/org/apache/spark/sql/internal/SessionState.scala
Loading
Please register or sign in to comment