Hi,
for that you would have to look at how Combine.PerKey and GroupByKey are
translated. We use a GroupAlsoByWindowViaWindowSetDoFn that internally uses
a ReduceFnRunner to manage all the windowing. The windowing strategy as
well as the SystemReduceFn is passed to
Hi,
I am trying to understand how Flink Runner tells the Flink system about the
triggers defined using Beam API. In the source code of Flink runner, the
WindowBoundTranslator passes the windowingStrategy to the
FlinkParDoBoundWrapper which does not seem to use it? How is the triggering
