pyflink.datastream.functions.ProcessWindowFunction

class ProcessWindowFunction(*args, **kwds)

Base interface for functions that are evaluated over keyed (grouped) 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(key, context, elements)	Evaluates the window and outputs none or several elements.