[jira] [Updated] (SPARK-39632) add state utils to StreamTest to check states during streaming queries

[Marco (Jira)]

Title: Message Title

Marco updated an issue   Spark / SPARK-39632 add state utils to StreamTest to check states during streaming queries Change By: Marco The framework for implementing tests for streaming queries ([StreamTest|https://github.com/apache/spark/blob/master/sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamTest.scala]) doesn't have any StreamActions that allows to check the state for a specific key during a stateful streaming query.  For this purpose, two new Stream Actions need to be implemented: {code:java} case class CheckEmptyState[K](expectedKey: K) extends StreamAction case class CheckNonEmptyState[K, V](expectedKey: K, expectedState: V) extends StreamAction{code} The CheckEmptyState StreamAction will check if doesn't exists a state for the specified key. The CheckNonEmptyState StreamAction will check if there is a state of type V, for the specified key, which is equal equals to the specified state. Add Comment   This message was sent by Atlassian Jira (v8.20.10#820010-sha1:ace47f9)