Package com.scaleoutsoftware.collections.timewindowing

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