You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@spark.apache.org by "Richard Xin (JIRA)" <ji...@apache.org> on 2017/11/20 18:40:00 UTC

[jira] [Created] (SPARK-22565) Session-based windowing

Richard Xin created SPARK-22565:
-----------------------------------

             Summary: Session-based windowing
                 Key: SPARK-22565
                 URL: https://issues.apache.org/jira/browse/SPARK-22565
             Project: Spark
          Issue Type: Improvement
          Components: Structured Streaming
    Affects Versions: 2.2.0
            Reporter: Richard Xin


I came across a requirement to support session-based windowing. for example, user activity comes in from kafka, we want to create window per user session (if the time gap of activity from the same user exceeds the predefined value, a new window will be created).

I noticed that Flink does support this kind of support, any plan/schedule for spark for this? 



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@spark.apache.org
For additional commands, e-mail: issues-help@spark.apache.org