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 GroupAlsoByWindowViaWindowSetDoFn.create() to create an actual instance of GroupAlsoByWindowViaWindowSetDoFn.
Cheers, Aljoscha On Mon, 25 Jul 2016 at 17:55 Shen Li <[email protected]> wrote: > 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 > information passed to Flink? > > Thanks, > > Shen >
