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: [email protected]
For additional commands, e-mail: [email protected]
