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 7cbfc2cad078 [SPARK-50422][SQL] Make `Parameterized SQL queries` of
`SparkSession.sql` API GA
add 02bfce6056ec [SPARK-50302][SS] Ensure secondary index sizes equal
primary index sizes for TransformWithState stateful variables with TTL
No new revisions were added by this update.
Summary of changes:
.../execution/streaming/ListStateImplWithTTL.scala | 125 ++--
.../execution/streaming/MapStateImplWithTTL.scala | 94 +--
.../streaming/StateTypesEncoderUtils.scala | 77 ++-
.../streaming/StatefulProcessorHandleImpl.scala | 2 +-
.../spark/sql/execution/streaming/TTLState.scala | 679 ++++++++++++++-------
.../streaming/ValueStateImplWithTTL.scala | 61 +-
.../execution/streaming/state/ListStateSuite.scala | 15 +-
.../streaming/state/ValueStateSuite.scala | 15 +-
.../streaming/TransformWithListStateTTLSuite.scala | 277 ++++++++-
.../streaming/TransformWithMapStateTTLSuite.scala | 3 +-
.../sql/streaming/TransformWithStateTTLTest.scala | 79 ++-
.../TransformWithValueStateTTLSuite.scala | 6 +-
12 files changed, 965 insertions(+), 468 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
