Window#

Window#

TimeWindow(start, end)

Window that represents a time interval from start (inclusive) to end (exclusive).

CountWindow(id)

A Window that represents a count window.

Trigger#

TriggerResult(value)

Result type for trigger methods.

WindowAssigner#

MergingWindowAssigner(*args, **kwds)

A WindowAssigner that can merge windows.