Jungtaek Lim created SPARK-40443:
------------------------------------
Summary: Support applyInPandasWithState in batch query
Key: SPARK-40443
URL: https://issues.apache.org/jira/browse/SPARK-40443
Project: Spark
Issue Type: Sub-task
Components: Structured Streaming
Affects Versions: 3.4.0
Reporter: Jungtaek Lim
In Scala/Java, flatMapGroupsWithState API uses different physical plan for
batch query, which applies some wrap-up with user function to effectively match
up with user function in MapGroupsExec.
This seems to be non-trivial to deal with in PySpark, or at least seems to
require major work. This ticket tracks the effort of supporting the API in
batch query.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org
For additional commands, e-mail: issues-h...@spark.apache.org
