Page History

...

To express the semantics of full window processing on DataStream, we need to define the corresponding method in DataStream class. One approach is to directly add add a window(WindowAssigner assigner) method. This method only supports passing the EndOfStreamWindows introduced in FLIP-331. In the job code, if full window processing is desired, the corresponding code should be dataStream.window(EndOfStreamWindows.get()).

However, this approach may lead users to mistakenly pass window assigners other than EndOfStreamWindows, which is not supported.

...