Uses of Interface
com.scaleoutsoftware.collections.timewindowing.TimestampSelector

Uses of TimestampSelector in com.scaleoutsoftware.collections.timewindowing

Fields in com.scaleoutsoftware.collections.timewindowing declared as TimestampSelector

Modifier and Type	Field	Description
TimestampSelector<T>	WindowingCollection._timestampSelector	The timestamp selector is used to select a timestamp from an element in the source collection.
protected TimestampSelector<T>	WatermarkedWindowingCollection.timestampSelector	The timestamp selector is used to select a timestamp from an element in the source collection.

Methods in com.scaleoutsoftware.collections.timewindowing that return TimestampSelector

Modifier and Type	Method	Description
TimestampSelector<T>	WatermarkedWindowingCollection.getTimestampSelector()	Retrieve the timestamp selector.

Methods in com.scaleoutsoftware.collections.timewindowing with parameters of type TimestampSelector

Modifier and Type	Method	Description
static <T> void	Utils.addTimeOrdered(List<T> source, TimestampSelector<T> selector, T toAdd)	Adds an item to the parameter source collection in chronological order.
static <T> void	Utils.performEviction(List<T> sourceCollection, TimestampSelector<T> timestampSelector, long removeBeforeMs)	Removes items from the parameter source collection that have timestamps before the start time
static <T> EvictionMetadata<T>	Utils.performWatermarkedWindowedEviction(List<T> sourceCollection, TimestampSelector<T> timestampSelector, long watermarkMs, long windowSizeMs, long everyMs, long nextWindowStartTimeMs)	Removes items from the parameter source collection that have timestamps before the watermark.
static <T> Iterable<TimeWindow<T>>	Windowing.toSessionWindows(List<T> sourceCollection, TimestampSelector<T> timestampSelector, long startTimeMs, long endTimeMs, long timeoutDurationMs)	Transforms a List into an iterable collection of session TimeWindows.
static <T> Iterable<TimeWindow<T>>	Windowing.toSlidingWindows(List<T> sourceCollection, TimestampSelector<T> timestampSelector, long startTimeMs, long endTimeMs, long windowDurationMs, long everyDurationMs)	Transforms a List into an iterable collection of sliding TimeWindows
static <T> Iterable<TimeWindow<T>>	Windowing.toTumblingWindows(List<T> sourceCollection, TimestampSelector<T> timestampSelector, long startTimeMs, long endTimeMs, long windowDurationMs)	Transforms a List into an iterable collection of tumbling TimeWindows.

Constructors in com.scaleoutsoftware.collections.timewindowing with parameters of type TimestampSelector

Modifier	Constructor	Description
	SessionWindowCollection(List<T> sourceCollection, TimestampSelector<T> timestampSelector, long startTimeMs, long timeoutMs)	Instantiates a new SessionWindowCollection
	SlidingWindowCollection(List<T> sourceCollection, TimestampSelector<T> timestampSelector, long startTimeMs, long windowDurationMs, long everyMs)	Instantiates a new SlidingWindowCollection
	TumblingWindowCollection(List<T> sourceCollection, TimestampSelector<T> timestampSelector, long startTimeMs, long windowDurationMs)	Instantiates a new tumbling window collection.
	WatermarkedSessionWindowCollection(List<T> sourceCollection, TimestampSelector<T> timestampSelector, long startTimeMs, long timeoutMs, WatermarkGenerator watermarkGenerator)	Instantiates a new SessionWindowCollection
	WatermarkedSessionWindowCollection(List<T> sourceCollection, TimestampSelector<T> timestampSelector, long nextWindowStartTimeMs, long timeoutMs, WatermarkGenerator watermarkGenerator, long currentWatermarkMs)	Instantiates a new SessionWindowCollection
	WatermarkedSlidingWindowCollection(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 WatermarkedTumblingWindowCollection
	WatermarkedTumblingWindowCollection(List<T> sourceCollection, TimestampSelector<T> timestampSelector, long nextWindowStartTimeMs, long windowDurationMs, WatermarkGenerator watermarkGenerator, long currentWatermarkMs)	Instantiates a new WatermarkedTumblingWindowCollection
	WatermarkedWindowingCollection(List<T> sourceCollection, TimestampSelector<T> timestampSelector, long startTimeMs, WatermarkGenerator watermarkGenerator)	Instantiates a new SlidingWindowCollection
	WindowingCollection(List<T> sourceCollection, TimestampSelector<T> timestampSelector, long startTimeMs)	Instantiate a new WindowingCollection.