Amit Sela created BEAM-920:
------------------------------
Summary: Support triggers and panes in streaming.
Key: BEAM-920
URL: https://issues.apache.org/jira/browse/BEAM-920
Project: Beam
Issue Type: Bug
Components: runner-spark
Reporter: Amit Sela
Assignee: Amit Sela
Use Spark's {{mapWithState}} operator to maintain accumulated state across
(micro) batches and the SDK to decide when to trigger and how to accumulate
across panes.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
