Bhuwan Sahni

[SS][SPARK-46928] Add support for ListState in Arbitrary State API v2.

1

### What changes were proposed in this pull request? This PR adds changes for ListState implementation in State Api v2. As a list contains multiple values for a single key,...

[SPARK-47036][SS] Cleanup RocksDB file tracking for previously uploaded files if files were deleted from local directory

1

### What changes were proposed in this pull request? This change cleans up any dangling files tracked as being previously uploaded if they were cleaned up from the filesystem. The...

Add support for total samples calculation in query stats.

17

This PR adds support for calculating total samples during a query, and returning this result as query statistics. Issue: https://github.com/thanos-community/promql-engine/issues/148 Prometheus defines `totalQueryableSamples` as the total number of samples read...

[SPARK-48511][SS] Remove TimeMode None from TransformWithState.

6

### What changes were proposed in this pull request? This PR removes the TimeMode None from supported time modes in TransformWithState operator. A structured streaming query works in either Processing...

### What changes were proposed in this pull request? Currently, we have a scenario where if a version X is loaded (and there is an existing snapshot with version X),...