This is an automated email from the ASF dual-hosted git repository.
kabhwan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
from 8a75e12f96a1 [SPARK-51228][SQL] Introduce subquery normalization to
NormalizePlan
add 17b943106b71 [SPARK-51237][SS] Add API details for new
transformWithState helper APIs as needed
No new revisions were added by this update.
Summary of changes:
.../spark/sql/streaming/ExpiredTimerInfo.scala | 4 +-
.../org/apache/spark/sql/streaming/ListState.scala | 46 ++++++++++++--
.../org/apache/spark/sql/streaming/MapState.scala | 73 +++++++++++++++++++---
.../org/apache/spark/sql/streaming/QueryInfo.scala | 24 +++++--
.../spark/sql/streaming/StatefulProcessor.scala | 16 +++++
.../sql/streaming/StatefulProcessorHandle.scala | 16 ++++-
.../apache/spark/sql/streaming/TimerValues.scala | 9 ++-
.../apache/spark/sql/streaming/ValueState.scala | 25 ++++++--
8 files changed, 184 insertions(+), 29 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
