Thanks for your explanation Max. I will take a look. Best, tison.
Maximilian Michels <m...@apache.org> 于2020年1月21日周二 下午11:45写道： > Hi Tison, > > Beam has its own set of libraries to implement windowing. Hence, the > Flink Runner does not use Flink's windowing but deploys Beam's windowing > logic within a Flink operator. If you want to look in the code, have a > look at WindowDoFnOperator. > > Cheers, > Max > > On 21.01.20 10:35, tison wrote: > > Hi guys, > > > > I'm curious that how does BEAM translate its AccumulationMode such > > as DISCARDING_FIRED_PANES and ACCUMULATING_FIRED_PANES to Flink Runner > > implementation. Since I don't find directly respective concept in Flink > > world it puzzles me a lot. > > > > Best, > > tison. >
