Namespace Scaleout.Streaming.TimeWindowing

Classes

SessionWindowCollection<T>

Transforms a collection into an enumerable collection of session windows and manages eviction of old items from the source collection. This wrapper can be used to manage the retention policy of the underlying collection. Objects added through this wrapper are inserted in chronologial order and evicted according to the policy provided to the constructor.

SlidingWindowCollection<T>

Transforms a collection into an enumerable collection of overlapping time windows and manages eviction of old items from the source collection. This wrapper can be used to manage the retention policy of the underlying collection. Objects added through this wrapper are inserted in chronologial order and evicted according to the startTime policy provided to the constructor.

TumblingWindowCollection<T>

Transforms a collection into an enumerable collection of fixed-time windows and manages eviction of old items from the source collection. This wrapper can be used to manage the retention policy of the underlying collection. Objects added through this wrapper are inserted in chronologial order and evicted according to the startTime policy provided to the constructor.

Interfaces

ITimeWindow<TElement>

Supports iteration over a collection of elements that fall within a time window.