matar993 opened a new pull request, #37026:
URL: https://github.com/apache/spark/pull/37026

   ### What changes were proposed in this pull request?
   This PR aims to allow the user to check the state during a streaming query 
execution.
   It is possible to check how the state is updated on each batch execution.
   
   ### Why are the changes needed?
   The changes are needed in order to:
   - check if exists a state for a specific key
   - check the value of the state for a specific key
   - check the state expiration.
   
   All these checks can be done during a streaming query execution.
   
   ### Does this PR introduce _any_ user-facing change?
   No.
   
   ### How was this patch tested?
   Add tests in StatefulStreamSuite class.
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to