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

[Marco (Jira)]

Title: Message Title

Marco created an issue   Spark / SPARK-39632 add state utils to StreamTest to check states during streaming queries Issue Type: New Feature Affects Versions: 3.3.0 Assignee: Unassigned Components: SQL, Tests Created: 29/Jun/22 13:40 Priority: Minor Reporter: Marco The framework for implementing tests for streaming queries (StreamTest) 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:   case class CheckEmptyState[K](expectedKey: K) extends StreamAction case class CheckNonEmptyState[K, V](expectedKey: K, expectedState: V) extends StreamAction   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 to the specified state. Add Comment   This message was sent by Atlassian Jira (v8.20.10#820010-sha1:ace47f9)