com.scaleoutsoftware.streaming.timewindowing

Class TumblingWindowCollection<T>

java.lang.Object

com.scaleoutsoftware.streaming.timewindowing.TumblingWindowCollection<T>

All Implemented Interfaces:

java.lang.Iterable<TimeWindow<T>>

public class TumblingWindowCollection<T>
extends java.lang.Object
implements java.lang.Iterable<TimeWindow<T>>

The TumblingWindowCollection transforms a collection into an iterable collection of sequential time windows. This wrapper class can be used to manage the retention policy and add objects in chronological order to the underlying source collection.

Constructor Summary

Constructors

Constructor and Description
TumblingWindowCollection(java.util.List<T> source, TimestampSelector<T> selector, long windowDuration, long startTime)

Method Summary

Modifier and Type	Method and Description
void	add(T item)
void	forEach(java.util.function.Consumer<? super TimeWindow<T>> action)
java.util.Iterator<TimeWindow<T>>	iterator()
java.util.Spliterator<TimeWindow<T>>	spliterator()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TumblingWindowCollection

public TumblingWindowCollection(java.util.List<T> source,
                                TimestampSelector<T> selector,
                                long windowDuration,
                                long startTime)

Method Detail

add

public void add(T item)

iterator

public java.util.Iterator<TimeWindow<T>> iterator()

Specified by:

iterator in interface java.lang.Iterable<TimeWindow<T>>

forEach

public void forEach(java.util.function.Consumer<? super TimeWindow<T>> action)

Specified by:

forEach in interface java.lang.Iterable<TimeWindow<T>>

spliterator

public java.util.Spliterator<TimeWindow<T>> spliterator()

Specified by:

spliterator in interface java.lang.Iterable<TimeWindow<T>>