Class SessionWindowExtensions

Provides extension method for session windowing.

Inheritance

System.Object

SessionWindowExtensions

Inherited Members

System.Object.ToString()

System.Object.Equals(System.Object)

System.Object.Equals(System.Object, System.Object)

System.Object.ReferenceEquals(System.Object, System.Object)

System.Object.GetHashCode()

System.Object.GetType()

System.Object.MemberwiseClone()

Namespace: Scaleout.Streaming.TimeWindowing.Linq

Assembly: Scaleout.Streaming.TimeWindowing.dll

Syntax

public static class SessionWindowExtensions

Methods

ToSessionWindows<TSource>(IEnumerable<TSource>, Func<TSource, DateTime>, TimeSpan)

Transforms a collection into an enumerable collection of session windows. The source collection must be sorted chronologically.

Declaration

public static IEnumerable<ITimeWindow<TSource>> ToSessionWindows<TSource>(this IEnumerable<TSource> source, Func<TSource, DateTime> timestampSelector, TimeSpan idleThreshold)

Parameters

Type	Name	Description
System.Collections.Generic.IEnumerable<TSource>	source	The sequence of elements to transform.
System.Func<TSource, System.DateTime>	timestampSelector	A function to extract a timestamp from an element.
System.TimeSpan	idleThreshold	Maximum allowed time gap between elements before a new session window is started.

Returns

Type	Description
System.Collections.Generic.IEnumerable<ITimeWindow<TSource>>	An enumerable set of ITimeWindow<TElement> collections.

Type Parameters

Name	Description
TSource	The type of objects in the source collection.