Uses of Interface
com.scaleoutsoftware.collections.timewindowing.WatermarkGenerator
-
Uses of WatermarkGenerator in com.scaleoutsoftware.collections.timewindowing
Classes in com.scaleoutsoftware.collections.timewindowing that implement WatermarkGeneratorModifier and TypeClassDescriptionclassThe DefaultWatermarkGenerator does not change the default implementation of the TimeWindowing eviction.classThe LatenessToleranceWatermarkGenerator generates watermarks with a constant lateness tolerance.Fields in com.scaleoutsoftware.collections.timewindowing declared as WatermarkGeneratorModifier and TypeFieldDescriptionprotected WatermarkGeneratorWatermarkedWindowingCollection.watermarkGeneratorThe watermark generator is used to generate a watermark for the windowing collection.Methods in com.scaleoutsoftware.collections.timewindowing that return WatermarkGeneratorModifier and TypeMethodDescriptionWatermarkedWindowingCollection.getWatermarkGenerator()Retrieve the watermark generator.Constructors in com.scaleoutsoftware.collections.timewindowing with parameters of type WatermarkGeneratorModifierConstructorDescriptionWatermarkedSessionWindowCollection(List<T> sourceCollection, TimestampSelector<T> timestampSelector, long startTimeMs, long timeoutMs, WatermarkGenerator watermarkGenerator) Instantiates a new SessionWindowCollectionWatermarkedSessionWindowCollection(List<T> sourceCollection, TimestampSelector<T> timestampSelector, long nextWindowStartTimeMs, long timeoutMs, WatermarkGenerator watermarkGenerator, long currentWatermarkMs) Instantiates a new SessionWindowCollectionWatermarkedSlidingWindowCollection(List<T> sourceCollection, TimestampSelector<T> timestampSelector, long startTimeMs, long windowDurationMs, long everyMs, WatermarkGenerator watermarkGenerator) Instantiates a new WatermarkedSlidingWindowCollection.WatermarkedSlidingWindowCollection(List<T> sourceCollection, TimestampSelector<T> timestampSelector, long nextWindowStartTimeMs, long windowDurationMs, long everyMs, WatermarkGenerator watermarkGenerator, long currentWatermarkMs) Instantiates a new WatermarkedSlidingWindowCollection.WatermarkedTumblingWindowCollection(List<T> sourceCollection, TimestampSelector<T> timestampSelector, long startTimeMs, long windowDurationMs, WatermarkGenerator watermarkGenerator) Instantiates a new WatermarkedTumblingWindowCollectionWatermarkedTumblingWindowCollection(List<T> sourceCollection, TimestampSelector<T> timestampSelector, long nextWindowStartTimeMs, long windowDurationMs, WatermarkGenerator watermarkGenerator, long currentWatermarkMs) Instantiates a new WatermarkedTumblingWindowCollectionWatermarkedWindowingCollection(List<T> sourceCollection, TimestampSelector<T> timestampSelector, long startTimeMs, WatermarkGenerator watermarkGenerator) Instantiates a new SlidingWindowCollection