Hi Aljoscha, Thanks a lot for your help!
Shen On Mon, Jul 25, 2016 at 12:31 PM, Aljoscha Krettek <[email protected]> wrote: > 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 > > >
