- class ProcessWindowFunction(*args, **kwds)[source]#
Base interface for functions that are evaluated over keyed (grouped) windows using a context for retrieving extra information.
Deletes any state in the
Contextwhen the Window expires (the watermark passes its max_timestamp + allowed_lateness).
process(key, content, elements)
Evaluates the window and outputs none or several elements.