This is an automated email from the ASF dual-hosted git repository.
wenchen pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git.
from 3bef2dc Revert "[SPARK-34757][CORE][DEPLOY] Ignore cache for SNAPSHOT
dependencies in spark-submit"
add 45235ac [SPARK-34748][SS] Create a rule of the analysis logic for
streaming write
No new revisions were added by this update.
Summary of changes:
.../sql/catalyst/streaming/WriteToStream.scala} | 23 +++--
.../streaming/WriteToStreamStatement.scala | 61 ++++++++++++++
.../execution/streaming/MicroBatchExecution.scala | 17 ++--
.../execution/streaming/ResolveWriteToStream.scala | 97 ++++++++++++++++++++++
.../sql/execution/streaming/StreamExecution.scala | 2 +-
.../streaming/continuous/ContinuousExecution.scala | 18 ++--
.../sql/internal/BaseSessionStateBuilder.scala | 2 +
.../sql/streaming/StreamingQueryManager.scala | 81 ++++--------------
.../spark/sql/hive/HiveSessionStateBuilder.scala | 2 +
9 files changed, 211 insertions(+), 92 deletions(-)
copy
sql/{core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/WriteToContinuousDataSource.scala
=>
catalyst/src/main/scala/org/apache/spark/sql/catalyst/streaming/WriteToStream.scala}
(65%)
create mode 100644
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/streaming/WriteToStreamStatement.scala
create mode 100644
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/ResolveWriteToStream.scala
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
