[ https://issues.apache.org/jira/browse/BEAM-84?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Amit Sela updated BEAM-84: -------------------------- Component/s: runner-spark > Add support for Session Windows - Beam Sessions > ----------------------------------------------- > > Key: BEAM-84 > URL: https://issues.apache.org/jira/browse/BEAM-84 > Project: Beam > Issue Type: New Feature > Components: runner-spark > Reporter: Amit Sela > > Implement Beam Sessions, or Session Windows, by maintaining the session > state. Spark 1.6 presents mapWithState as an improvement to updateStateByKey > so It'd be better to use it. > See "Session Windows" in Dataflow documentation here: > https://cloud.google.com/dataflow/model/windowing#Functions > Also, this blog post from Databricks would be a good place to start: > https://databricks.com/blog/2016/02/01/faster-stateful-stream-processing-in-spark-streaming.html -- This message was sent by Atlassian JIRA (v6.3.4#6332)