Jungtaek Lim created SPARK-52333:
------------------------------------

             Summary: Squeeze protocol for timers (list on specific grouping 
key, and expiry timers)
                 Key: SPARK-52333
                 URL: https://issues.apache.org/jira/browse/SPARK-52333
             Project: Spark
          Issue Type: Improvement
          Components: PySpark, Structured Streaming
    Affects Versions: 4.1.0
            Reporter: Jungtaek Lim


Likewise we did for ListState and MapState, we figured out inlining timers into 
proto message would give the huge benefit on the state interaction 
(intercommunication). This ticket aims to address the same change to listing 
timers for grouping key and expiry timers.



--
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

Reply via email to