An event is a wrapper object that gets stored in the window.
Context information that can be used by the eviction policy.
Eviction policy tracks events and decides whether an event should be evicted from the window or not.
Interface to be implemented for extracting timestamp from a tuple.
The callback fired by
Triggers the window calculations based on the policy.
A view of events in a sliding window.
A callback for expiry, activation of events tracked by the
An eviction policy that tracks event counts and can evict based on a threshold count.
A trigger that tracks event counts and calls back
Window manager that handles windows with state persistence.
Eviction policy that evicts events based on time duration.
Holds the expired, new and current tuples in a window.
An iterator based implementation over the events in a window.
An eviction policy that tracks count based on watermark ts and evicts events up to the watermark based on a threshold count.
A trigger policy that tracks event counts and sets the context for eviction policy to evict based on latest watermark time.
Watermark event used for tracking progress of time when processing event based ts.
Tracks tuples across input streams and periodically emits watermark events.
An eviction policy that evicts events based on time duration taking watermark time and event lag into account.
Handles watermark events and triggers
The action to be taken when
Copyright © 2021 The Apache Software Foundation. All rights reserved.