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 60acd2fe442c [SPARK-50261][SQL] Fix error signature for invalid
fraction of a second
add e4638c888cf3 [SPARK-49899][PYTHON][SS] Support deleteIfExists for
TransformWithStateInPandas
No new revisions were added by this update.
Summary of changes:
python/pyspark/sql/pandas/group_ops.py | 16 +++
.../sql/streaming/proto/StateMessage_pb2.py | 144 ++++++++++-----------
.../sql/streaming/proto/StateMessage_pb2.pyi | 12 +-
python/pyspark/sql/streaming/stateful_processor.py | 6 +
.../sql/streaming/stateful_processor_api_client.py | 15 +++
.../pandas/test_pandas_transform_with_state.py | 11 +-
python/pyspark/worker.py | 11 ++
.../sql/execution/streaming/StateMessage.proto | 1 +
.../TransformWithStateInPandasStateServer.scala | 11 ++
...ransformWithStateInPandasStateServerSuite.scala | 11 ++
10 files changed, 163 insertions(+), 75 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
