This is an automated email from the ASF dual-hosted git repository.
ashrigondekar pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
from 19ff85950c35 [SPARK-54379] [SQL] Move lambda binding to separate
`LambdaBinder` object
add 1c283c01493a [SPARK-54063][SS] Trigger snapshot for next batch when
upload lag
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/spark/internal/LogKeys.java | 1 +
.../org/apache/spark/sql/internal/SQLConf.scala | 23 +++
.../streaming/ClientStreamingQuerySuite.scala | 1 +
.../state/HDFSBackedStateStoreProvider.scala | 32 +++-
.../sql/execution/streaming/state/RocksDB.scala | 6 +-
.../state/RocksDBStateStoreProvider.scala | 44 +++--
.../sql/execution/streaming/state/StateStore.scala | 64 ++++---
.../streaming/state/StateStoreCoordinator.scala | 64 ++++++-
.../RocksDBStateStoreCheckpointFormatV2Suite.scala | 12 +-
.../state/RocksDBStateStoreIntegrationSuite.scala | 2 +-
.../execution/streaming/state/RocksDBSuite.scala | 6 +-
.../state/StateStoreCoordinatorSuite.scala | 204 ++++++++++++++++++++-
.../streaming/state/StateStoreSuite.scala | 28 ++-
.../apache/spark/sql/internal/SQLConfSuite.scala | 35 ++++
.../apache/spark/sql/streaming/StreamSuite.scala | 5 +-
15 files changed, 467 insertions(+), 60 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
