IIUC RETRACTING_FIRED_PANES is not yet implemented but only a placeholder, is it?
Best, tison. tison <[email protected]> 于2020年1月21日周二 下午11:59写道： > Thanks for your explanation Max. I will take a look. > > Best, > tison. > > > Maximilian Michels <[email protected]> 于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. >> >
