pyflink.datastream.data_stream.AllWindowedStream.apply

AllWindowedStream.apply(window_function: AllWindowFunction, output_type: Optional[TypeInformation] = None) → DataStream

Applies the given window function to each window. The window function is called for each evaluation of the window. The output of the window function is interpreted as a regular non-windowed stream.

Note that this function requires that all data in the windows is buffered until the window is evaluated, as the function provides no means of incremental aggregation.

Parameters

• window_function – The window function.

• output_type – Type information for the result type of the window function.

Returns

The data stream that is the result of applying the window function to the window.