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 811482a79cbc [SPARK-54290][SS] Skip checksum creation if path already
exists without checksum
add 32f3a29e21c5 [SPARK-54264][SS] DeDup Operator can use RocksDB's
keyExists()
No new revisions were added by this update.
Summary of changes:
.../operators/stateful/statefulOperators.scala | 4 +-
.../sql/execution/streaming/state/RocksDB.scala | 20 ++++++
.../state/RocksDBStateStoreProvider.scala | 9 +++
.../sql/execution/streaming/state/StateStore.scala | 23 +++++++
.../RocksDBStateStoreCheckpointFormatV2Suite.scala | 6 ++
.../execution/streaming/state/RocksDBSuite.scala | 73 ++++++++++++++++++++++
6 files changed, 133 insertions(+), 2 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
