CepStream Class

 

Provides the extension methods used for writing LINQ queries over a stream of CEP events.

Namespace:   Microsoft.ComplexEventProcessing.Linq
Assembly:  Microsoft.ComplexEventProcessing (in Microsoft.ComplexEventProcessing.dll)

Inheritance Hierarchy

System.Object
  Microsoft.ComplexEventProcessing.Linq.CepStream

Syntax

public static class CepStream
[ExtensionAttribute]
public ref class CepStream abstract sealed 
[<AbstractClass>]
[<Sealed>]
type CepStream = class end
<ExtensionAttribute>
Public NotInheritable Class CepStream

Methods

Name Description
System_CAPS_pubmethodSystem_CAPS_static AlterEventDuration<TPayload>(CepStream<TPayload>, Expression<Func<CepEvent<TPayload>, TimeSpan>>)

Changes the duration of the input events. This method does not change the start time of an event.

System_CAPS_pubmethodSystem_CAPS_static AlterEventLifetime<TPayload>(CepStream<TPayload>, Expression<Func<CepEvent, DateTime>>, Expression<Func<CepEvent<TPayload>, TimeSpan>>)

Alters the lifetime of the events in the stream. This method can change both the start time and end time of an event.

System_CAPS_pubmethodSystem_CAPS_static ClipEventDuration<TSource, TClip>(CepStream<TSource>, CepStream<TClip>, Expression<Func<TSource, TClip, Boolean>>)

Shortens the lifetime of events in sourceStream to the start time of the next corresponding event in clipStream, matched by matchExpression.

System_CAPS_pubmethodSystem_CAPS_static CountByStartTimeWindow<TPayload>(CepStream<TPayload>, UInt32)

Groups input stream events into windows of events based on a given number of unique event start times using the default output policy. The window slides when a new event arrives that starts at a different time.

System_CAPS_pubmethodSystem_CAPS_static CountByStartTimeWindow<TPayload>(CepStream<TPayload>, UInt32, CountWindowOutputPolicy)

Groups input stream events into windows of events based on a given number of unique event start times. The window slides when a new event arrives that starts at a different time.

System_CAPS_pubmethodSystem_CAPS_static CountByStartTimeWindow<TPayload>(CepStream<TPayload>, UInt32, WindowInputPolicy, CountWindowOutputPolicy)

Groups input stream events into windows of events based on a given number of unique event start times. The window slides when a new event arrives that starts at a different time.

System_CAPS_pubmethodSystem_CAPS_static GroupBy<TPayload, TGroupingKey>(CepStream<TPayload>, Expression<Func<TPayload, TGroupingKey>>)

Partitions the input stream by the specified grouping key.

System_CAPS_pubmethodSystem_CAPS_static GroupBy<TPayload, TGroupingKey, TResult>(CepStream<TPayload>, Expression<Func<TPayload, TGroupingKey>>, Expression<Func<TPayload, TResult>>)

Groups the source stream by the specified key selector functions and projects results using the element selector function.

System_CAPS_pubmethodSystem_CAPS_static HoppingWindow<TPayload>(CepStream<TPayload>, TimeSpan, TimeSpan)

Transforms a stream to a window stream where each member is a CepWindow using the default output policy.

System_CAPS_pubmethodSystem_CAPS_static HoppingWindow<TPayload>(CepStream<TPayload>, TimeSpan, TimeSpan, DateTime)

Transforms a stream to a window stream where each member is a CepWindow using the default output policy.

System_CAPS_pubmethodSystem_CAPS_static HoppingWindow<TPayload>(CepStream<TPayload>, TimeSpan, TimeSpan, DateTime, HoppingWindowOutputPolicy)

Transforms a stream to a window stream where each member is a CepWindow.

System_CAPS_pubmethodSystem_CAPS_static HoppingWindow<TPayload>(CepStream<TPayload>, TimeSpan, TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy)

The window is defined by constant window size and hop size timespans.

System_CAPS_pubmethodSystem_CAPS_static HoppingWindow<TPayload>(CepStream<TPayload>, TimeSpan, TimeSpan, HoppingWindowOutputPolicy)

Transforms a stream to a window stream where each member is a CepWindow using the default output policy.

System_CAPS_pubmethodSystem_CAPS_static HoppingWindow<TPayload>(CepStream<TPayload>, TimeSpan, TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy)

Transforms a stream to a window stream where each member is a CepWindow using the default output policy.

System_CAPS_pubmethodSystem_CAPS_static IsEmpty<TPayload>(CepStream<TPayload>)

Performs a left anti-semi-join (LASJ) query on the specified stream.

System_CAPS_pubmethodSystem_CAPS_static Join<TOuter, TInner, TKey, TResult>(CepStream<TOuter>, CepStream<TInner>, Expression<Func<TOuter, TKey>>, Expression<Func<TInner, TKey>>, Expression<Func<TOuter, TInner, TResult>>)

Joins the events from the outer stream with events from the inner stream on the given join key.

System_CAPS_pubmethodSystem_CAPS_static OrderBy<TPayload, TOrderKey>(CepOrderableStream<TPayload>, Expression<Func<TPayload, TOrderKey>>)

Orders the input stream by the rankSelector.

System_CAPS_pubmethodSystem_CAPS_static OrderByDescending<TPayload, TOrderKey>(CepOrderableStream<TPayload>, Expression<Func<TPayload, TOrderKey>>)

Orders the input stream by the rankSelector in descending order.

System_CAPS_pubmethodSystem_CAPS_static Scan<TInputEvent, TInputPayload, TOutputPayload>(CepStream<TInputPayload>, CepStreamOperator<TInputEvent, TInputPayload, TOutputPayload>)

Scans an input stream using a user-defined stream operator.

System_CAPS_pubmethodSystem_CAPS_static Select<TInput, TResult>(CepOrderedStream<TInput>, Expression<Func<TInput, TResult>>)

Given an ordered stream, this method produces an ordered stream that can be used for ranking.

System_CAPS_pubmethodSystem_CAPS_static Select<TPayload, TResult>(CepStream<TPayload>, Expression<Func<TPayload, TResult>>)

Projects events from input stream using a projections expression.

System_CAPS_pubmethodSystem_CAPS_static Select<TInput, TResult>(CepWindowStream<CepWindow<TInput>>, Expression<Func<CepWindow<TInput>, TResult>>)

Maps a window stream to a stream based on a given mapping expression.

System_CAPS_pubmethodSystem_CAPS_static Select<TInput, TOutput>(ICepEnumerable<TInput>, Expression<Func<TInput, TOutput>>)

Projects each event of an enumerable input stream into a new event.

System_CAPS_pubmethodSystem_CAPS_static SelectMany<TInput, TResult>(CepWindowStream<CepWindow<TInput>>, Expression<Func<CepWindow<TInput>, CepWindow<TInput>>>, Expression<Func<CepWindow<TInput>, TInput, TResult>>)

Supports order by operation against a windowed stream.

System_CAPS_pubmethodSystem_CAPS_static SelectMany<TInput, TBind, TResult>(CepStream<TInput>, Expression<Func<CepStream<TInput>, CepStream<TBind>>>, Expression<Func<TInput, TBind, TResult>>)

Produces a stream based on the cross join of two input streams.

System_CAPS_pubmethodSystem_CAPS_static SelectMany<TInput, TGroupingKey, TBind, TResult>(CepGroupingStreams<TInput, TGroupingKey>, Expression<Func<CepStream<TInput>, CepStream<TBind>>>, Expression<Func<IKey<TGroupingKey>, TBind, TResult>>)

Supports adding query logic inside a Group and Apply.

System_CAPS_pubmethodSystem_CAPS_static SelectMany<TInput, TGroupingKey, TBind, TResult>(CepGroupingStreams<TInput, TGroupingKey>, Expression<Func<CepStream<TInput>, CepWindowStream<TBind>>>, Expression<Func<IKey<TGroupingKey>, TBind, TResult>>)

Enables window operations on top of a grouping stream.

System_CAPS_pubmethodSystem_CAPS_static ShiftEventTime<TPayload>(CepStream<TPayload>, Expression<Func<CepEvent, DateTime>>)

Shift event times to the value specified by the shiftExpr parameter. The method does not change event life times.

System_CAPS_pubmethodSystem_CAPS_static ShiftEventTime<TPayload>(CepStream<TPayload>, Expression<Func<CepEvent, TimeSpan>>)

Shift event times by the amount specified by the shiftExpr parameter. The value returned may be positive or negative.

System_CAPS_pubmethodSystem_CAPS_static SnapshotWindow<TPayload>(CepStream<TPayload>)

Transforms a stream to a window stream where each member is a CepWindow using the default output policy.

System_CAPS_pubmethodSystem_CAPS_static SnapshotWindow<TPayload>(CepStream<TPayload>, SnapshotWindowOutputPolicy)

Transforms a stream to a window stream where each member is a CepWindow.

System_CAPS_pubmethodSystem_CAPS_static SnapshotWindow<TPayload>(CepStream<TPayload>, WindowInputPolicy, SnapshotWindowOutputPolicy)

Transforms a stream to a window stream where each member is a CepWindow.

System_CAPS_pubmethodSystem_CAPS_static Take<TPayload>(CepOrderedStream<TPayload>, UInt32)

Given an ordered stream, takes a given number of events from each window.

System_CAPS_pubmethodSystem_CAPS_static Take<TInput, TResult>(CepOrderedStream<TInput>, UInt32, Expression<Func<CepRankedEvent<TInput>, TResult>>)

Takes a given number of events from each window and also evaluate the given expression. This is used for cases in which you want to project the rank into the result of Take().

System_CAPS_pubmethodSystem_CAPS_static ThenBy<TPayload, TOrderKey>(CepOrderedStream<TPayload>, Expression<Func<TPayload, TOrderKey>>)

Orders an ordered stream by another order key as indicated by rankSelector.

System_CAPS_pubmethodSystem_CAPS_static ThenByDescending<TPayload, TOrderKey>(CepOrderedStream<TPayload>, Expression<Func<TPayload, TOrderKey>>)

Orders an ordered stream by another order key as indicated by rankSelector.

System_CAPS_pubmethodSystem_CAPS_static ToEdgeEnumerable<TPayload>(CepStream<TPayload>)

Converts a CepStream of edge events to an event sink that implements the IEnumerable interface.

System_CAPS_pubmethodSystem_CAPS_static ToEdgeEnumerable<TPayload>(CepStream<TPayload>, StreamEventOrder)

Converts a CepStream of edge events to an event sink that implements the IEnumerable interface.

System_CAPS_pubmethodSystem_CAPS_static ToEdgeStream<TInput, TPayload>(IEnumerable<TInput>, Application, Expression<Func<TInput, EdgeEvent<TPayload>>>, AdvanceTimeSettings, String)

Converts an enumerable input stream to a stream of edge events, and provides the temporal characteristics of the input.

System_CAPS_pubmethodSystem_CAPS_static ToEnumerable<TPayload>(CepStream<TPayload>)

Converts a stream of events to enumerable output by removing event headers and discarding CTI events.

System_CAPS_pubmethodSystem_CAPS_static ToEnumerable<TPayload>(CepStream<TPayload>, StreamEventOrder)

Converts a stream of events to enumerable output with the specified event order by removing event headers and discarding CTI events.

System_CAPS_pubmethodSystem_CAPS_static ToIntervalEnumerable<TPayload>(CepStream<TPayload>)

Converts a CepStream of interval events to an event sink that implements the IEnumerable interface. The order of events is FullyOrdered.

System_CAPS_pubmethodSystem_CAPS_static ToIntervalEnumerable<TPayload>(CepStream<TPayload>, StreamEventOrder)

Converts a CepStream of interval events with the specified event order to an event sink that implements the IEnumerable interface.

System_CAPS_pubmethodSystem_CAPS_static ToIntervalStream<TInput, TPayload>(IEnumerable<TInput>, Application, Expression<Func<TInput, IntervalEvent<TPayload>>>, AdvanceTimeSettings, String)

Converts an enumerable input stream to a stream of interval events, and provides the temporal characteristics of the input.

System_CAPS_pubmethodSystem_CAPS_static ToPointEnumerable<TPayload>(CepStream<TPayload>)

Converts a CepStream of point events to an event sink that implements the IEnumerable interface. The order of events is FullyOrdered.

System_CAPS_pubmethodSystem_CAPS_static ToPointEnumerable<TPayload>(CepStream<TPayload>, StreamEventOrder)

Converts a CepStream of point events with the specified event order to an event sink that implements the IEnumerable interface.

System_CAPS_pubmethodSystem_CAPS_static ToPointEventStream<TPayload>(CepStream<TPayload>)

Changes the events in an input stream to point events by keeping only the event start times.

System_CAPS_pubmethodSystem_CAPS_static ToPointStream<TInput, TPayload>(IEnumerable<TInput>, Application, Expression<Func<TInput, PointEvent<TPayload>>>, AdvanceTimeSettings, String)

Converts a CepStream of point events to an event sink.

System_CAPS_pubmethodSystem_CAPS_static ToStream<TPayload>(IEnumerable<EdgeEvent<TPayload>>, Application, AdvanceTimeSettings, String)

Converts a CepStream of point events to a stream.

System_CAPS_pubmethodSystem_CAPS_static ToStream<TPayload>(IEnumerable<IntervalEvent<TPayload>>, Application, AdvanceTimeSettings, String)

Converts a CepStream of point events to a stream.

System_CAPS_pubmethodSystem_CAPS_static ToStream<TPayload>(IEnumerable<PointEvent<TPayload>>, Application, AdvanceTimeSettings, String)

Converts a CepStream of point events to a stream.

System_CAPS_pubmethodSystem_CAPS_static TumblingWindow<TPayload>(CepStream<TPayload>, TimeSpan)

Transforms a stream to a window stream where each member is a CepWindow using the default output policy.

System_CAPS_pubmethodSystem_CAPS_static TumblingWindow<TPayload>(CepStream<TPayload>, TimeSpan, DateTime)

Transforms a stream to a window stream where each member is a CepWindow using the default output policy.

System_CAPS_pubmethodSystem_CAPS_static TumblingWindow<TPayload>(CepStream<TPayload>, TimeSpan, DateTime, HoppingWindowOutputPolicy)

Transforms a stream to a window stream where each member is a CepWindow.

System_CAPS_pubmethodSystem_CAPS_static TumblingWindow<TPayload>(CepStream<TPayload>, TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy)

Transforms a stream to a window stream where each member is a CepWindow.

System_CAPS_pubmethodSystem_CAPS_static TumblingWindow<TPayload>(CepStream<TPayload>, TimeSpan, HoppingWindowOutputPolicy)

Transforms a stream to a window stream where each member is a CepWindow.

System_CAPS_pubmethodSystem_CAPS_static TumblingWindow<TPayload>(CepStream<TPayload>, TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy)

Transforms a stream to a window stream where each member is a CepWindow.

System_CAPS_pubmethodSystem_CAPS_static Union<TPayload>(CepStream<TPayload>, CepStream<TPayload>)

Unions two streams together into one stream.

System_CAPS_pubmethodSystem_CAPS_static Where<TPayload>(CepStream<TPayload>, Expression<Func<TPayload, Boolean>>)

Filters events from an input stream using a given filter function.

System_CAPS_pubmethodSystem_CAPS_static Where<TInput>(ICepEnumerable<TInput>, Expression<Func<TInput, Boolean>>)

Filters events from an enumerable input stream using the specified filter expression.

Remarks

CepStream is a collection of the extension methods. In general, the extension methods return a LINQ method call expression. The method calls capture the invocation sequence in a canonical form that is later translated into a runnable CEP query.

Thread Safety

Any public static (Shared in Visual Basic) members of this type are thread safe. Any instance members are not guaranteed to be thread safe.

See Also

Microsoft.ComplexEventProcessing.Linq Namespace

Return to top