Help understand how Flink Runner translate triggering information

[Shen Li]

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