Hi all,
Triggers are one of the more novel aspects of Beam's support for unbounded
data. They are also one of the most challenging aspects of the model.
Ben & I have been working on a major new idea for how triggers could work
in the Beam model. We think it will make triggers much more usable, create
new opportunities for no-knobs execution/optimization, and improve
compatibility with DSLs like SQL. (also eliminate a whole class of bugs)
Triggering is for sinks!
https://s.apache.org/beam-sink-triggers
Please take a look at this "1"-pager and give feedback.
Kenn
