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 7087677cf185 [SPARK-51775][SQL] Normalize LogicalRelation and
HiveTableRelation by NormalizePlan
add bb1a63a8c361 [SPARK-51758][SS] Apply late record filtering based on
watermark only if timeMode is passed as EventTime to the transformWithState
operator
No new revisions were added by this update.
Summary of changes:
.../pandas/test_pandas_transform_with_state.py | 61 ++++++++++++++++++-
.../streaming/TransformWithStateInPandasExec.scala | 2 +-
.../streaming/TransformWithStateExec.scala | 2 +-
.../sql/streaming/TransformWithStateSuite.scala | 70 ++++++++++++++++++++++
4 files changed, 131 insertions(+), 4 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org
For additional commands, e-mail: commits-h...@spark.apache.org
