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.
