All Classes and Interfaces

Class
Description
The DefaultWatermarkGenerator does not change the default implementation of the TimeWindowing eviction.
Eviction metadata stores metadata for the result of an eviction routine.
The LatenessToleranceWatermarkGenerator generates watermarks with a constant lateness tolerance.
The SessionWindowCollection transforms a List into an iterable collection of session windows.
The SlidingWindowCollection transforms a collection into an iterable collection of overlapping time windows.
The TimestampSelector is used to pull a timestamp from an object.
Supports iteration over a collection of elements that fall within the given start and end timestamps.
The TumblingWindowCollection transforms a collection into an iterable collection of sequential time windows.
Helper functions used within the library.
The WatermarkedSessionWindowCollection transforms a List into an iterable collection of session windows.
The SlidingWindowCollection transforms a collection into an iterable collection of overlapping time windows.
The TumblingWindowCollection transforms a collection into an iterable collection of sequential time windows.
Used to transform a List into an iterable collection of TimeWindow.
The watermark generator is used to generate a watermark for the last seen event time.
Static functions that transform a List into an iterable collection of TimeWindows.
Used to transform a List into an iterable collection of TimeWindow.