This is an automated email from the ASF dual-hosted git repository.
gengliang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git.
from 95d9494 [SPARK-35339][PYTHON] Improve unit tests for data-type-based
basic operations
add 47485a3 [SPARK-35897][SS] Support user defined initial state with
flatMapGroupsWithState in Structured Streaming
No new revisions were added by this update.
Summary of changes:
.../analysis/UnsupportedOperationChecker.scala | 12 +
.../spark/sql/catalyst/plans/logical/object.scala | 65 ++++-
.../analysis/UnsupportedOperationsSuite.scala | 116 ++++++---
.../apache/spark/sql/KeyValueGroupedDataset.scala | 164 ++++++++++++
.../spark/sql/execution/SparkStrategies.scala | 10 +-
.../streaming/FlatMapGroupsWithStateExec.scala | 266 ++++++++++++++-----
.../execution/streaming/IncrementalExecution.scala | 6 +-
.../execution/streaming/statefulOperators.scala | 4 +-
.../apache/spark/sql/streaming/GroupState.scala | 5 +
.../org/apache/spark/sql/JavaDatasetSuite.java | 66 +++++
.../streaming/FlatMapGroupsWithStateSuite.scala | 283 ++++++++++++++++++++-
11 files changed, 875 insertions(+), 122 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org
For additional commands, e-mail: commits-h...@spark.apache.org
