pyflink.datastream.functions.WindowFunction

class WindowFunction(*args, **kwds)

Base interface for functions that are evaluated over keyed (grouped) windows.

Methods

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