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