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 aad5b6e19c6e [SPARK-54800] Changed default implementation for
isObjectNotFoundException
add 5e41971f2734 [SPARK-54411][SS] Introduce Repartition Writer that
Support Multi-CF
No new revisions were added by this update.
Summary of changes:
.../join/SymmetricHashJoinStateManager.scala | 4 +-
.../streaming/state/StatePartitionWriter.scala | 84 +-
.../v2/state/StateDataSourceTestBase.scala | 288 ++++++-
...tatePartitionAllColumnFamiliesReaderSuite.scala | 556 +++---------
...tatePartitionAllColumnFamiliesWriterSuite.scala | 927 ++++++++++++++++-----
.../util/TransformWithStateTestUtils.scala | 418 ++++++++++
6 files changed, 1613 insertions(+), 664 deletions(-)
create mode 100644
sql/core/src/test/scala/org/apache/spark/sql/streaming/util/TransformWithStateTestUtils.scala
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
