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.

GlobalWindow()

The default window into which all data is placed GlobalWindows.

Trigger#

TriggerResult(value)

Result type for trigger methods.

EventTimeTrigger(*args, **kwds)

A Trigger that fires once the watermark passes the end of the window to which a pane belongs.

ContinuousEventTimeTrigger(interval)

A Trigger that continuously fires based on a given time interval.

ProcessingTimeTrigger(*args, **kwds)

A Trigger that fires once the current system time passes the end of the window to which a pane belongs.

ContinuousProcessingTimeTrigger(interval)

A Trigger that continuously fires based on a given time interval as measured by the clock of the machine on which the job is running.

PurgingTrigger(nested_trigger)

A trigger that can turn any Trigger into a purging Trigger.

CountTrigger(window_size)

A Trigger that fires once the count of elements in a pane reaches the given count.

NeverTrigger(*args, **kwds)

A trigger that never fires, as default Trigger for GlobalWindows.

WindowAssigner#

MergingWindowAssigner(*args, **kwds)

A WindowAssigner that can merge windows.

CountTumblingWindowAssigner(window_size)

A WindowAssigner that windows elements into fixed-size windows based on the count number of the elements.

CountSlidingWindowAssigner(window_size, ...)

A WindowAssigner that windows elements into sliding windows based on the count number of the elements.

TumblingProcessingTimeWindows(size, offset)

A WindowAssigner that windows elements into windows based on the current system time of the machine the operation is running on.

TumblingEventTimeWindows(size, offset)

A WindowAssigner that windows elements into windows based on the timestamp of the elements.

SlidingProcessingTimeWindows(size, slide, offset)

A WindowAssigner that windows elements into sliding windows based on the current system time of the machine the operation is running on.

SlidingEventTimeWindows(size, slide, offset)

A WindowAssigner that windows elements into sliding windows based on the timestamp of the elements.

ProcessingTimeSessionWindows(session_gap)

A WindowAssigner that windows elements into sessions based on the current processing time.

EventTimeSessionWindows(session_gap)

A WindowAssigner that windows elements into sessions based on the timestamp of the elements.

DynamicProcessingTimeSessionWindows(...)

A WindowAssigner that windows elements into sessions based on the current processing time.

DynamicEventTimeSessionWindows(...)

A WindowAssigner that windows elements into sessions based on the timestamp of the elements.

GlobalWindows()

A WindowAssigner that assigns all elements to the same GlobalWindow.

SessionWindowTimeGapExtractor#

SessionWindowTimeGapExtractor()

A SessionWindowTimeGapExtractor extracts session time gaps for Dynamic Session Window Assigners.