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 27987536be38 [SPARK-47800][SQL] Create new method for identifier to
tableIdentifier conversion
add ae93b46b8c2b [SPARK-47733][SS] Add custom metrics for
transformWithState operator part of query progress
No new revisions were added by this update.
Summary of changes:
.../streaming/StatefulProcessorHandleImpl.scala | 28 +++++++++++++++++-----
.../spark/sql/execution/streaming/TTLState.scala | 16 +++++++++----
.../streaming/TransformWithStateExec.scala | 27 +++++++++++++++++++--
.../streaming/ValueStateImplWithTTL.scala | 5 +++-
.../state/HDFSBackedStateStoreProvider.scala | 2 +-
.../sql/execution/streaming/state/RocksDB.scala | 14 ++++++++++-
.../state/RocksDBStateStoreProvider.scala | 19 +++++++++++----
.../sql/execution/streaming/state/StateStore.scala | 2 +-
.../streaming/state/MemoryStateStore.scala | 2 +-
.../state/RocksDBStateStoreIntegrationSuite.scala | 3 ++-
.../execution/streaming/state/RocksDBSuite.scala | 2 ++
.../streaming/TransformWithListStateSuite.scala | 5 +++-
.../sql/streaming/TransformWithMapStateSuite.scala | 5 +++-
.../sql/streaming/TransformWithStateSuite.scala | 26 ++++++++++++++++++--
.../TransformWithValueStateTTLSuite.scala | 12 +++++++++-
15 files changed, 140 insertions(+), 28 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
