Index (timewindowing 2.0.1 API)

A C D E F G I L P S T U W _
All Classes and Interfaces|All Packages

A

add(T) - Method in class com.scaleoutsoftware.collections.timewindowing.WatermarkedWindowingCollection: Uses the watermark generator to generate a watermark from the parameter item.
add(T) - Method in class com.scaleoutsoftware.collections.timewindowing.WindowingCollection: Adds an item to the underlying source collection in chronological order.
addTimeOrdered(List<T>, TimestampSelector<T>, T) - Static method in class com.scaleoutsoftware.collections.timewindowing.Utils: Adds an item to the parameter source collection in chronological order.

C

com.scaleoutsoftware.collections.timewindowing - package com.scaleoutsoftware.collections.timewindowing

D

DefaultWatermarkGenerator - Class in com.scaleoutsoftware.collections.timewindowing: The DefaultWatermarkGenerator does not change the default implementation of the TimeWindowing eviction.
DefaultWatermarkGenerator(long) - Constructor for class com.scaleoutsoftware.collections.timewindowing.DefaultWatermarkGenerator: Instantiate the WatermarkGenerator with the start time of the windowing collection.

E

EvictionMetadata<T> - Class in com.scaleoutsoftware.collections.timewindowing: Eviction metadata stores metadata for the result of an eviction routine.
EvictionMetadata(List<TimeWindow<T>>) - Constructor for class com.scaleoutsoftware.collections.timewindowing.EvictionMetadata: Construct a new eviction metadata instance with a list of closed windows.

F

forEach(Consumer<? super TimeWindow<T>>) - Method in class com.scaleoutsoftware.collections.timewindowing.SessionWindowCollection
forEach(Consumer<? super TimeWindow<T>>) - Method in class com.scaleoutsoftware.collections.timewindowing.SlidingWindowCollection
forEach(Consumer<? super TimeWindow<T>>) - Method in class com.scaleoutsoftware.collections.timewindowing.TumblingWindowCollection
forEach(Consumer<? super TimeWindow<T>>) - Method in class com.scaleoutsoftware.collections.timewindowing.WatermarkedSessionWindowCollection
forEach(Consumer<? super TimeWindow<T>>) - Method in class com.scaleoutsoftware.collections.timewindowing.WatermarkedSlidingWindowCollection
forEach(Consumer<? super TimeWindow<T>>) - Method in class com.scaleoutsoftware.collections.timewindowing.WatermarkedTumblingWindowCollection

G

generateWatermark(long) - Method in class com.scaleoutsoftware.collections.timewindowing.DefaultWatermarkGenerator: Returns the start time of the windowing collection of which this WatermarkGenerator is associated with.
generateWatermark(long) - Method in class com.scaleoutsoftware.collections.timewindowing.LatenessToleranceWatermarkGenerator: Generates (or returns the existing) watermark based on the last seen event timestamp.
generateWatermark(long) - Method in interface com.scaleoutsoftware.collections.timewindowing.WatermarkGenerator: Generate (or return the existing) watermark for the last seen event timestamp.
getClosedWindows() - Method in class com.scaleoutsoftware.collections.timewindowing.EvictionMetadata: Retrieves the closed windows.
getEndTimeMs() - Method in interface com.scaleoutsoftware.collections.timewindowing.TimeWindow: Returns the end time of this window.
getEveryMs() - Method in class com.scaleoutsoftware.collections.timewindowing.WatermarkedSlidingWindowCollection: Retrieves the window created "every" in milliseconds.
getNextWindowStartTimeMs() - Method in class com.scaleoutsoftware.collections.timewindowing.EvictionMetadata: Retrieves the next window start time in milliseconds.
getNextWindowStartTimeMs() - Method in class com.scaleoutsoftware.collections.timewindowing.WatermarkedSlidingWindowCollection: Retrieves the next window start time in milliseconds.
getNextWindowStartTimeMs() - Method in class com.scaleoutsoftware.collections.timewindowing.WatermarkedTumblingWindowCollection: Retrieves the next window start time in milliseconds.
getSourceCollection() - Method in class com.scaleoutsoftware.collections.timewindowing.WatermarkedWindowingCollection: Retrieves the source collection.
getStartTimeMs() - Method in interface com.scaleoutsoftware.collections.timewindowing.TimeWindow: Returns the start time of this window.
getStartTimeMs() - Method in class com.scaleoutsoftware.collections.timewindowing.WatermarkedWindowingCollection: Retrieve the start time in milliseconds.
getTimeoutMs() - Method in class com.scaleoutsoftware.collections.timewindowing.WatermarkedSessionWindowCollection: Retrieve the configured session window timeout in milliseconds.
getTimestampSelector() - Method in class com.scaleoutsoftware.collections.timewindowing.WatermarkedWindowingCollection: Retrieve the timestamp selector.
getWatermarkGenerator() - Method in class com.scaleoutsoftware.collections.timewindowing.WatermarkedWindowingCollection: Retrieve the watermark generator.
getWatermarkMs() - Method in class com.scaleoutsoftware.collections.timewindowing.WatermarkedWindowingCollection: Return the current watermark in milliseconds.
getWindowContents() - Method in interface com.scaleoutsoftware.collections.timewindowing.TimeWindow: Retrieves the items of the window as a list.
getWindowDurationMs() - Method in class com.scaleoutsoftware.collections.timewindowing.WatermarkedSlidingWindowCollection: Retrieves the configured window duration in milliseconds.
getWindowDurationMs() - Method in class com.scaleoutsoftware.collections.timewindowing.WatermarkedTumblingWindowCollection: Retrieves the windows duration in milliseconds.

I

iterator() - Method in class com.scaleoutsoftware.collections.timewindowing.SessionWindowCollection
iterator() - Method in class com.scaleoutsoftware.collections.timewindowing.SlidingWindowCollection
iterator() - Method in class com.scaleoutsoftware.collections.timewindowing.TumblingWindowCollection
iterator() - Method in class com.scaleoutsoftware.collections.timewindowing.WatermarkedSessionWindowCollection
iterator() - Method in class com.scaleoutsoftware.collections.timewindowing.WatermarkedSlidingWindowCollection
iterator() - Method in class com.scaleoutsoftware.collections.timewindowing.WatermarkedTumblingWindowCollection

L

LatenessToleranceWatermarkGenerator - Class in com.scaleoutsoftware.collections.timewindowing: The LatenessToleranceWatermarkGenerator generates watermarks with a constant lateness tolerance.
LatenessToleranceWatermarkGenerator(long) - Constructor for class com.scaleoutsoftware.collections.timewindowing.LatenessToleranceWatermarkGenerator: Constructs a new LatenessToleranceWatermarkGenerator with a constant lateness tolerance.
LatenessToleranceWatermarkGenerator(long, long) - Constructor for class com.scaleoutsoftware.collections.timewindowing.LatenessToleranceWatermarkGenerator: Constructs a new LatenessToleranceWatermarkGenerator with a constant lateness tolerance and the current watermark in milliseconds.

P

performEviction(List<T>, TimestampSelector<T>, long) - Static method in class com.scaleoutsoftware.collections.timewindowing.Utils: Removes items from the parameter source collection that have timestamps before the start time
performWatermarkedWindowedEviction(List<T>, TimestampSelector<T>, long, long, long, long) - Static method in class com.scaleoutsoftware.collections.timewindowing.Utils: Removes items from the parameter source collection that have timestamps before the watermark.

S

select(T) - Method in interface com.scaleoutsoftware.collections.timewindowing.TimestampSelector: Select the timestamp from an item.
SessionWindowCollection<T> - Class in com.scaleoutsoftware.collections.timewindowing: The SessionWindowCollection transforms a List into an iterable collection of session windows.
SessionWindowCollection(List<T>, TimestampSelector<T>, long, long) - Constructor for class com.scaleoutsoftware.collections.timewindowing.SessionWindowCollection: Instantiates a new SessionWindowCollection
size() - Method in interface com.scaleoutsoftware.collections.timewindowing.TimeWindow: Returns the size of the iterable collection.
SlidingWindowCollection<T> - Class in com.scaleoutsoftware.collections.timewindowing: The SlidingWindowCollection transforms a collection into an iterable collection of overlapping time windows.
SlidingWindowCollection(List<T>, TimestampSelector<T>, long, long, long) - Constructor for class com.scaleoutsoftware.collections.timewindowing.SlidingWindowCollection: Instantiates a new SlidingWindowCollection
sourceCollection - Variable in class com.scaleoutsoftware.collections.timewindowing.WatermarkedWindowingCollection: The source collection of items for the watermarked windowing collection.
spliterator() - Method in class com.scaleoutsoftware.collections.timewindowing.SessionWindowCollection
spliterator() - Method in class com.scaleoutsoftware.collections.timewindowing.SlidingWindowCollection
spliterator() - Method in class com.scaleoutsoftware.collections.timewindowing.TumblingWindowCollection
spliterator() - Method in class com.scaleoutsoftware.collections.timewindowing.WatermarkedSessionWindowCollection
spliterator() - Method in class com.scaleoutsoftware.collections.timewindowing.WatermarkedSlidingWindowCollection
spliterator() - Method in class com.scaleoutsoftware.collections.timewindowing.WatermarkedTumblingWindowCollection
startTimeMs - Variable in class com.scaleoutsoftware.collections.timewindowing.WatermarkedWindowingCollection: The inclusive start time of first window of a windowing collection.

T

timestampSelector - Variable in class com.scaleoutsoftware.collections.timewindowing.WatermarkedWindowingCollection: The timestamp selector is used to select a timestamp from an element in the source collection.
TimestampSelector<T> - Interface in com.scaleoutsoftware.collections.timewindowing: The TimestampSelector is used to pull a timestamp from an object.
TimeWindow<T> - Interface in com.scaleoutsoftware.collections.timewindowing: Supports iteration over a collection of elements that fall within the given start and end timestamps.
toSessionWindows(List<T>, TimestampSelector<T>, long, long, long) - Static method in class com.scaleoutsoftware.collections.timewindowing.Windowing: Transforms a List into an iterable collection of session TimeWindows.
toSlidingWindows(List<T>, TimestampSelector<T>, long, long, long, long) - Static method in class com.scaleoutsoftware.collections.timewindowing.Windowing: Transforms a List into an iterable collection of sliding TimeWindows
toTumblingWindows(List<T>, TimestampSelector<T>, long, long, long) - Static method in class com.scaleoutsoftware.collections.timewindowing.Windowing: Transforms a List into an iterable collection of tumbling TimeWindows.
TumblingWindowCollection<T> - Class in com.scaleoutsoftware.collections.timewindowing: The TumblingWindowCollection transforms a collection into an iterable collection of sequential time windows.
TumblingWindowCollection(List<T>, TimestampSelector<T>, long, long) - Constructor for class com.scaleoutsoftware.collections.timewindowing.TumblingWindowCollection: Instantiates a new tumbling window collection.

U

Utils - Class in com.scaleoutsoftware.collections.timewindowing: Helper functions used within the library.

W

WatermarkedSessionWindowCollection<T> - Class in com.scaleoutsoftware.collections.timewindowing: The WatermarkedSessionWindowCollection transforms a List into an iterable collection of session windows.
WatermarkedSessionWindowCollection(List<T>, TimestampSelector<T>, long, long, WatermarkGenerator) - Constructor for class com.scaleoutsoftware.collections.timewindowing.WatermarkedSessionWindowCollection: Instantiates a new SessionWindowCollection
WatermarkedSessionWindowCollection(List<T>, TimestampSelector<T>, long, long, WatermarkGenerator, long) - Constructor for class com.scaleoutsoftware.collections.timewindowing.WatermarkedSessionWindowCollection: Instantiates a new SessionWindowCollection
WatermarkedSlidingWindowCollection<T> - Class in com.scaleoutsoftware.collections.timewindowing: The SlidingWindowCollection transforms a collection into an iterable collection of overlapping time windows.
WatermarkedSlidingWindowCollection(List<T>, TimestampSelector<T>, long, long, long, WatermarkGenerator) - Constructor for class com.scaleoutsoftware.collections.timewindowing.WatermarkedSlidingWindowCollection: Instantiates a new WatermarkedSlidingWindowCollection.
WatermarkedSlidingWindowCollection(List<T>, TimestampSelector<T>, long, long, long, WatermarkGenerator, long) - Constructor for class com.scaleoutsoftware.collections.timewindowing.WatermarkedSlidingWindowCollection: Instantiates a new WatermarkedSlidingWindowCollection.
WatermarkedTumblingWindowCollection<T> - Class in com.scaleoutsoftware.collections.timewindowing: The TumblingWindowCollection transforms a collection into an iterable collection of sequential time windows.
WatermarkedTumblingWindowCollection(List<T>, TimestampSelector<T>, long, long, WatermarkGenerator) - Constructor for class com.scaleoutsoftware.collections.timewindowing.WatermarkedTumblingWindowCollection: Instantiates a new WatermarkedTumblingWindowCollection
WatermarkedTumblingWindowCollection(List<T>, TimestampSelector<T>, long, long, WatermarkGenerator, long) - Constructor for class com.scaleoutsoftware.collections.timewindowing.WatermarkedTumblingWindowCollection: Instantiates a new WatermarkedTumblingWindowCollection
WatermarkedWindowingCollection<T> - Class in com.scaleoutsoftware.collections.timewindowing: Used to transform a List into an iterable collection of TimeWindow.
WatermarkedWindowingCollection(List<T>, TimestampSelector<T>, long, WatermarkGenerator) - Constructor for class com.scaleoutsoftware.collections.timewindowing.WatermarkedWindowingCollection: Instantiates a new SlidingWindowCollection
watermarkGenerator - Variable in class com.scaleoutsoftware.collections.timewindowing.WatermarkedWindowingCollection: The watermark generator is used to generate a watermark for the windowing collection.
WatermarkGenerator - Interface in com.scaleoutsoftware.collections.timewindowing: The watermark generator is used to generate a watermark for the last seen event time.
watermarkMs - Variable in class com.scaleoutsoftware.collections.timewindowing.WatermarkedWindowingCollection: The current watermark of the windowing collection.
Windowing - Class in com.scaleoutsoftware.collections.timewindowing: Static functions that transform a List into an iterable collection of TimeWindows.
WindowingCollection<T> - Class in com.scaleoutsoftware.collections.timewindowing: Used to transform a List into an iterable collection of TimeWindow.
WindowingCollection(List<T>, TimestampSelector<T>, long) - Constructor for class com.scaleoutsoftware.collections.timewindowing.WindowingCollection: Instantiate a new WindowingCollection.

_

_sourceCollection - Variable in class com.scaleoutsoftware.collections.timewindowing.WindowingCollection: The source collection of items for a windowing collection.
_startTimeMs - Variable in class com.scaleoutsoftware.collections.timewindowing.WindowingCollection: The inclusive start time of first window of a windowing collection.
_timestampSelector - Variable in class com.scaleoutsoftware.collections.timewindowing.WindowingCollection: The timestamp selector is used to select a timestamp from an element in the source collection.

A C D E F G I L P S T U W _
All Classes and Interfaces|All Packages