spark
spark copied to clipboard
[SPARK-49899][PYTHON][SS] Support deleteIfExists for TransformWithStateInPandas
What changes were proposed in this pull request?
- Support deleteIfExists for TransformWithStateInPandas.
- Added
close()
support for StatefulProcessor.
Why are the changes needed?
Add parity to TransformWithStateInPandas for functionalities we support in TransformWithState
Does this PR introduce any user-facing change?
Yes
How was this patch tested?
New unit test.
Was this patch authored or co-authored using generative AI tooling?
No