|
AlterEventDuration<TPayload> |
Alters the duration of events without affecting start time. |
|
AlterEventLifetime<TPayload> |
Alters the lifetime of events. |
|
AlterEventStartTime<TPayload> |
Alters the start time of events without affecting duration. |
|
ClipEventDuration<TSource, TClip>(IQStreamable<TSource>, IQStreamable<TClip>, Expression<Func<TSource, TClip, Boolean>>) |
Clips the end time of events in source to the start time of the next corresponding event in clip matching predicate. |
|
ClipEventDuration<TSource, TClip, TKey>(IQStreamable<TSource>, IQStreamable<TClip>, Expression<Func<TSource, TKey>>, Expression<Func<TClip, TKey>>) |
Clips the end time of events in source to the start time of the next corresponding event in clip with a equivalent key value. |
|
CountWindow<TPayload> |
Produces a windowed stream based on a count. Each window consists of events with count unique start times. The window slides when a new event arrives with a distinct start time. |
|
GroupBy<TPayload, TKey>(IQStreamable<TPayload>, Expression<Func<TPayload, TKey>>) |
Partition operator. |
|
GroupBy<TSource, TKey, TResult>(IQStreamable<TSource>, Expression<Func<TSource, TKey>>, Expression<Func<TSource, TResult>>) |
Partition operator. |
|
HoppingWindow<TPayload>(IQStreamable<TPayload>, TimeSpan, TimeSpan) |
Produces a windowed stream based on window definition. Hopping windows are characterized by a window duration and a hop size representing the window period. |
|
HoppingWindow<TPayload>(IQStreamable<TPayload>, TimeSpan, TimeSpan, DateTime) |
Produces a windowed stream based on window definition. Hopping windows are characterized by a window duration and a hop size representing the window period. |
|
Join<TLeft, TRight, TKey, TResult> |
Joins events with coincident lifetimes and matching key values. |
|
LeftAntiJoin<TLeft, TRight>(IQStreamable<TLeft>, IQStreamable<TRight>, Expression<Func<TLeft, TRight, Boolean>>) |
Returns left events when they do not coincide with any matching right events where events are matched based on predicate. |
|
LeftAntiJoin<TLeft, TRight, TKey>(IQStreamable<TLeft>, IQStreamable<TRight>, Expression<Func<TLeft, TKey>>, Expression<Func<TRight, TKey>>) |
Returns left events when they do not coincide with any matching right events where events are matched by key. |
|
Multicast<TSource, TResult> |
Multicast operator. |
|
OrderBy<TPayload, TKey> |
Orders the contents of a window based on a key. |
|
OrderByDescending<TPayload, TKey> |
Orders the contents of a window based on a key in descending order. |
|
Scan<TSourceEvent, TSource, TResult> |
Scans a stream using a user-defined stream operator. |
|
Select<TSource, TResult>(IQOrderedWindow<TSource>, Expression<Func<TSource, TResult>>) |
Projection operator over ordered window. |
|
Select<TSource, TResult>(IQStreamable<TSource>, Expression<Func<TSource, TResult>>) |
Projection operator. |
|
Select<TSource, TResult>(IQWindowedStreamable<TSource>, Expression<Func<CepWindow<TSource>, TResult>>) |
Projection method supporting aggregate computations over windows. |
|
SelectMany<TSource, TResult>(IQWindowedStreamable<TSource>, Expression<Func<IQWindowSource<TSource>, IQWindowResult<TResult>>>) |
Binds operator returning a stream of results given a function from window to window results. |
|
SelectMany<TKey, TSource, TResult>(IQPartitionedStreamable<TKey, TSource>, Expression<Func<IQStreamable<TSource>, IQStreamable<TResult>>>) |
Merges operator for partitioned stream. |
|
SelectMany<TLeft, TRight, TResult>(IQStreamable<TLeft>, Expression<Func<Unit, IQStreamable<TRight>>>, Expression<Func<TLeft, TRight, TResult>>) |
Cross-join operator. |
|
SelectMany<TSource, TBind, TResult>(IQWindowedStreamable<TSource>, Expression<Func<IQWindowSource<TSource>, IQWindowResult<TBind>>>, Expression<Func<Unit, TBind, TResult>>) |
Binds operator returning a stream of results given a function from window to window results. |
|
SelectMany<TKey, TSource, TBind, TResult>(IQPartitionedStreamable<TKey, TSource>, Expression<Func<IQStreamable<TSource>, IQStreamable<TBind>>>, Expression<Func<IKey<TKey>, TBind, TResult>>) |
Merges operator for partitioned stream. |
|
SelectMany<TKey, TSource, TBind, TResult>(IQPartitionedStreamable<TKey, TSource>, Expression<Func<IQStreamable<TSource>, IQWindowedStreamable<TBind>>>, Expression<Func<IKey<TKey>, CepWindow<TBind>, TResult>>) |
Merges aggregate operator for partitioned stream. |
|
ShiftEventTime<TPayload> |
Shifts events by offsets specified by the shiftSelector parameter. |
|
SnapshotWindow<TPayload> |
Produces a windowed stream based on snapshots. Windows are defined by event boundaries in source. |
|
Take<TPayload>(IQOrderedWindow<TPayload>, UInt32) |
Takes the top count elements from an ordered window. If there are ties, all elements with the lowest rank are returned. |
|
Take<TSource, TResult>(IQOrderedWindow<TSource>, UInt32, Expression<Func<CepRankedEvent<TSource>, TResult>>) |
Takes the top count elements from an ordered window. If there are ties, all elements with the lowest rank are returned. |
|
ThenBy<TPayload, TKey> |
Adds an ordering key to an ordered window definition. |
|
ThenByDescending<TPayload, TKey> |
Adds an ordering key to an ordered window definition where the key is used for descending order. |
|
ToPointEventStream<TPayload> |
Turns events in the input stream into point events. |
|
TumblingWindow<TPayload>(IQStreamable<TPayload>, TimeSpan) |
Produces a windowed stream based on window definition. |
|
TumblingWindow<TPayload>(IQStreamable<TPayload>, TimeSpan, DateTime) |
Produces a windowed stream based on window definition. |
|
Union<TPayload> |
Union operator. |
|
UserDefinedOperator<TSource, TResult>(IQWindowSource<TSource>, Expression<Func<CepOperator<TSource, TResult>>>) |
Applies a user-defined operator to a window. |
|
UserDefinedOperator<TSource, TResult>(IQWindowSource<TSource>, Expression<Func<CepTimeSensitiveOperator<TSource, TResult>>>) |
Applies a user-defined operator to a window. |
|
Where<TPayload> |
Selection operator. |