Beam implements Windowing itself (via state and timers) rather than deferring to Flink's implementation.
On Wed, Jun 12, 2024 at 11:55 AM Ruben Vargas <[email protected]> wrote: > > Hello guys > > May be a silly question, > > But in the Flink runner, the window implementation uses the Flink > windowing? Does that mean the runner will have performance issues like > Flink itself? see this: > https://issues.apache.org/jira/browse/FLINK-7001 > > I'm asking because I see the issue, it mentions different concepts > that Beam already handles at the API level. So my suspicion is that > the Beam model handles windowing a little differently from the pure > Flink app. But I'm not sure.. > > > Regards.
