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 a window(WindowAssigner assigner)  window(WindowAssigner assigner) methodmethod to DataStream. This method only supports passing the EndOfStreamWindows introduced in FLIP-331. The If users want to apply full window processing, the corresponding job code will bedataStream.window(EndOfStreamWindows.get())if full window processing is desired.

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

...