pyflink.datastream.functions.ProcessAllWindowFunction

class ProcessAllWindowFunction(*args, **kwds)

Base interface for functions that are evaluated over non-keyed windows using a context for retrieving extra information.

Methods

clear(context)	Deletes any state in the Context when the Window expires (the watermark passes its max_timestamp + allowed_lateness).
close()
open(runtime_context)
process(context, elements)	Evaluates the window and outputs none or several elements.