-
- Downloads
[SPARK-15953][WIP][STREAMING] Renamed ContinuousQuery to StreamingQuery
Renamed for simplicity, so that its obvious that its related to streaming. Existing unit tests. Author: Tathagata Das <tathagata.das1565@gmail.com> Closes #13673 from tdas/SPARK-15953.
Showing
- python/pyspark/sql/context.py 4 additions, 4 deletionspython/pyspark/sql/context.py
- python/pyspark/sql/dataframe.py 1 addition, 1 deletionpython/pyspark/sql/dataframe.py
- python/pyspark/sql/readwriter.py 20 additions, 20 deletionspython/pyspark/sql/readwriter.py
- python/pyspark/sql/session.py 5 additions, 5 deletionspython/pyspark/sql/session.py
- python/pyspark/sql/streaming.py 39 additions, 40 deletionspython/pyspark/sql/streaming.py
- python/pyspark/sql/tests.py 26 additions, 26 deletionspython/pyspark/sql/tests.py
- python/pyspark/sql/utils.py 4 additions, 4 deletionspython/pyspark/sql/utils.py
- sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala 2 additions, 2 deletionssql/core/src/main/scala/org/apache/spark/sql/Dataset.scala
- sql/core/src/main/scala/org/apache/spark/sql/ForeachWriter.scala 2 additions, 2 deletions...e/src/main/scala/org/apache/spark/sql/ForeachWriter.scala
- sql/core/src/main/scala/org/apache/spark/sql/SQLContext.scala 4 additions, 4 deletions...core/src/main/scala/org/apache/spark/sql/SQLContext.scala
- sql/core/src/main/scala/org/apache/spark/sql/SparkSession.scala 3 additions, 3 deletions...re/src/main/scala/org/apache/spark/sql/SparkSession.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/SQLExecution.scala 1 addition, 1 deletion...n/scala/org/apache/spark/sql/execution/SQLExecution.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/SparkStrategies.scala 2 additions, 2 deletions...cala/org/apache/spark/sql/execution/SparkStrategies.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala 13 additions, 13 deletions...pache/spark/sql/execution/streaming/StreamExecution.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamingQueryListenerBus.scala 14 additions, 14 deletions...k/sql/execution/streaming/StreamingQueryListenerBus.scala
- sql/core/src/main/scala/org/apache/spark/sql/functions.scala 3 additions, 3 deletionssql/core/src/main/scala/org/apache/spark/sql/functions.scala
- sql/core/src/main/scala/org/apache/spark/sql/internal/SQLConf.scala 2 additions, 2 deletions...rc/main/scala/org/apache/spark/sql/internal/SQLConf.scala
- sql/core/src/main/scala/org/apache/spark/sql/internal/SessionState.scala 4 additions, 4 deletions...in/scala/org/apache/spark/sql/internal/SessionState.scala
- sql/core/src/main/scala/org/apache/spark/sql/streaming/DataStreamWriter.scala 8 additions, 8 deletions...ala/org/apache/spark/sql/streaming/DataStreamWriter.scala
- sql/core/src/main/scala/org/apache/spark/sql/streaming/StreamingQuery.scala 5 additions, 5 deletions...scala/org/apache/spark/sql/streaming/StreamingQuery.scala
Loading
Please register or sign in to comment