pyflink.datastream.functions.AllWindowFunction

class AllWindowFunction(*args, **kwds)

Base interface for functions that are evaluated over non-keyed windows.

Methods

apply(window, inputs)	Evaluates the window and outputs none or several elements.
close()
open(runtime_context)