...
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.
...