Uses of Interface
com.scaleoutsoftware.collections.timewindowing.TimeWindow
-
Uses of TimeWindow in com.scaleoutsoftware.collections.timewindowing
Methods in com.scaleoutsoftware.collections.timewindowing that return types with arguments of type TimeWindowModifier and TypeMethodDescriptionList<TimeWindow<T>> Uses the watermark generator to generate a watermark from the parameter item.List<TimeWindow<T>> EvictionMetadata.getClosedWindows()Retrieves the closed windows.SessionWindowCollection.iterator()SlidingWindowCollection.iterator()TumblingWindowCollection.iterator()WatermarkedSessionWindowCollection.iterator()WatermarkedSlidingWindowCollection.iterator()WatermarkedTumblingWindowCollection.iterator()SessionWindowCollection.spliterator()SlidingWindowCollection.spliterator()TumblingWindowCollection.spliterator()WatermarkedSessionWindowCollection.spliterator()WatermarkedSlidingWindowCollection.spliterator()WatermarkedTumblingWindowCollection.spliterator()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 TimeWindowsstatic <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.Method parameters in com.scaleoutsoftware.collections.timewindowing with type arguments of type TimeWindowModifier and TypeMethodDescriptionvoidSessionWindowCollection.forEach(Consumer<? super TimeWindow<T>> action) voidSlidingWindowCollection.forEach(Consumer<? super TimeWindow<T>> action) voidTumblingWindowCollection.forEach(Consumer<? super TimeWindow<T>> action) voidWatermarkedSessionWindowCollection.forEach(Consumer<? super TimeWindow<T>> action) voidWatermarkedSlidingWindowCollection.forEach(Consumer<? super TimeWindow<T>> action) voidWatermarkedTumblingWindowCollection.forEach(Consumer<? super TimeWindow<T>> action) Constructor parameters in com.scaleoutsoftware.collections.timewindowing with type arguments of type TimeWindowModifierConstructorDescriptionEvictionMetadata(List<TimeWindow<T>> closedWindows) Construct a new eviction metadata instance with a list of closed windows.