anishshri-db commented on code in PR #44961:
URL: https://github.com/apache/spark/pull/44961#discussion_r1474920558
##########
sql/api/src/main/scala/org/apache/spark/sql/streaming/StatefulProcessorHandle.scala:
##########
@@ -43,4 +43,15 @@ private[sql] trait StatefulProcessorHandle extends
Serializable {
/** Function to return queryInfo for currently running task */
def getQueryInfo(): QueryInfo
+
+ /**
+ * Creates new or returns existing list state associated with stateName.
+ * The ListState persists values of type T.
+ * @param stateName - name of the state variable
+ * @param keyEncoder - Spark SQL Encoder for key
+ * @tparam K - type of key
+ * @tparam T - type of state variable
+ * @return - instance of ListState of type T that can be used to store state
persistently
+ */
+ def getListState[K, T](stateName: String, keyEncoder: Encoder[K]):
ListState[T]
Review Comment:
You can merge back from master once ? we are passing `keyEncoder` through
the operator now - so won't need to add it here
--
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]
