Export (0) Print
Expand All

CepStream Class

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

System.Object
  Microsoft.ComplexEventProcessing.Linq.CepStream

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

public static class CepStream

The CepStream type exposes the following members.

  NameDescription
Public methodStatic memberAlterEventDuration<TPayload>Changes the duration of the input events. This method does not change the start time of an event.
Public methodStatic memberAlterEventLifetime<TPayload>Alters the lifetime of the events in the stream. This method can change both the start time and end time of an event.
Public methodStatic memberClipEventDuration<TSource, TClip> Shortens the lifetime of events in sourceStream to the start time of the next corresponding event in clipStream, matched by matchExpression.
Public methodStatic memberCountByStartTimeWindow<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.
Public methodStatic memberCountByStartTimeWindow<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.
Public methodStatic memberCountByStartTimeWindow<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.
Public methodStatic memberGroupBy<TPayload, TGroupingKey>(CepStream<TPayload>, Expression<Func<TPayload, TGroupingKey>>)Partitions the input stream by the specified grouping key.
Public methodStatic memberGroupBy<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.
Public methodStatic memberHoppingWindow<TPayload>(CepStream<TPayload>, TimeSpan, TimeSpan)Transforms a stream to a window stream where each member is a CepWindow using the default output policy.
Public methodStatic memberHoppingWindow<TPayload>(CepStream<TPayload>, TimeSpan, TimeSpan, HoppingWindowOutputPolicy)Transforms a stream to a window stream where each member is a CepWindow using the default output policy.
Public methodStatic memberHoppingWindow<TPayload>(CepStream<TPayload>, TimeSpan, TimeSpan, DateTime)Transforms a stream to a window stream where each member is a CepWindow using the default output policy.
Public methodStatic memberHoppingWindow<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.
Public methodStatic memberHoppingWindow<TPayload>(CepStream<TPayload>, TimeSpan, TimeSpan, DateTime, HoppingWindowOutputPolicy)Transforms a stream to a window stream where each member is a CepWindow.
Public methodStatic memberHoppingWindow<TPayload>(CepStream<TPayload>, TimeSpan, TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy)The window is defined by constant window size and hop size timespans.
Public methodStatic memberIsEmpty<TPayload>Performs a left anti-semi-join (LASJ) query on the specified stream.
Public methodStatic memberJoin<TOuter, TInner, TKey, TResult>Joins the events from the outer stream with events from the inner stream on the given join key.
Public methodStatic memberOrderBy<TPayload, TOrderKey>Orders the input stream by the rankSelector.
Public methodStatic memberOrderByDescending<TPayload, TOrderKey>Orders the input stream by the rankSelector in descending order.
Public methodStatic memberScan<TInputEvent, TInputPayload, TOutputPayload>Scans an input stream using a user-defined stream operator.
Public methodStatic memberSelect<TInput, TResult>(CepOrderedStream<TInput>, Expression<Func<TInput, TResult>>)Given an ordered stream, this method produces an ordered stream that can be used for ranking.
Public methodStatic memberSelect<TPayload, TResult>(CepStream<TPayload>, Expression<Func<TPayload, TResult>>)Projects events from input stream using a projections expression.
Public methodStatic memberSelect<TInput, TResult>(CepWindowStream<CepWindow<TInput>>, Expression<Func<CepWindow<TInput>, TResult>>)Maps a window stream to a stream based on a given mapping expression.
Public methodStatic memberSelect<TInput, TOutput>(ICepEnumerable<TInput>, Expression<Func<TInput, TOutput>>)Projects each event of an enumerable input stream into a new event.
Public methodStatic memberSelectMany<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.
Public methodStatic memberSelectMany<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.
Public methodStatic memberSelectMany<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.
Public methodStatic memberSelectMany<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.
Public methodStatic memberShiftEventTime<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.
Public methodStatic memberShiftEventTime<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.
Public methodStatic memberSnapshotWindow<TPayload>(CepStream<TPayload>)Transforms a stream to a window stream where each member is a CepWindow using the default output policy.
Public methodStatic memberSnapshotWindow<TPayload>(CepStream<TPayload>, SnapshotWindowOutputPolicy)Transforms a stream to a window stream where each member is a CepWindow.
Public methodStatic memberSnapshotWindow<TPayload>(CepStream<TPayload>, WindowInputPolicy, SnapshotWindowOutputPolicy)Transforms a stream to a window stream where each member is a CepWindow.
Public methodStatic memberTake<TPayload>(CepOrderedStream<TPayload>, UInt32)Given an ordered stream, takes a given number of events from each window.
Public methodStatic memberTake<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().
Public methodStatic memberThenBy<TPayload, TOrderKey>Orders an ordered stream by another order key as indicated by rankSelector.
Public methodStatic memberThenByDescending<TPayload, TOrderKey> Orders an ordered stream by another order key as indicated by rankSelector.
Public methodStatic memberToEdgeEnumerable<TPayload>(CepStream<TPayload>)Converts a CepStream of edge events to an event sink that implements the IEnumerable interface.
Public methodStatic memberToEdgeEnumerable<TPayload>(CepStream<TPayload>, StreamEventOrder)Converts a CepStream of edge events to an event sink that implements the IEnumerable interface.
Public methodStatic memberToEdgeStream<TInput, TPayload>Converts an enumerable input stream to a stream of edge events, and provides the temporal characteristics of the input.
Public methodStatic memberToEnumerable<TPayload>(CepStream<TPayload>)Converts a stream of events to enumerable output by removing event headers and discarding CTI events.
Public methodStatic memberToEnumerable<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.
Public methodStatic memberToIntervalEnumerable<TPayload>(CepStream<TPayload>)Converts a CepStream of interval events to an event sink that implements the IEnumerable interface. The order of events is FullyOrdered.
Public methodStatic memberToIntervalEnumerable<TPayload>(CepStream<TPayload>, StreamEventOrder)Converts a CepStream of interval events with the specified event order to an event sink that implements the IEnumerable interface.
Public methodStatic memberToIntervalStream<TInput, TPayload>Converts an enumerable input stream to a stream of interval events, and provides the temporal characteristics of the input.
Public methodStatic memberToPointEnumerable<TPayload>(CepStream<TPayload>)Converts a CepStream of point events to an event sink that implements the IEnumerable interface. The order of events is FullyOrdered.
Public methodStatic memberToPointEnumerable<TPayload>(CepStream<TPayload>, StreamEventOrder)Converts a CepStream of point events with the specified event order to an event sink that implements the IEnumerable interface.
Public methodStatic memberToPointEventStream<TPayload>Changes the events in an input stream to point events by keeping only the event start times.
Public methodStatic memberToPointStream<TInput, TPayload>Converts a CepStream of point events to an event sink.
Public methodStatic memberToStream<TPayload>(IEnumerable<EdgeEvent<TPayload>>, Application, AdvanceTimeSettings, String)Converts a CepStream of point events to a stream.
Public methodStatic memberToStream<TPayload>(IEnumerable<IntervalEvent<TPayload>>, Application, AdvanceTimeSettings, String)Converts a CepStream of point events to a stream.
Public methodStatic memberToStream<TPayload>(IEnumerable<PointEvent<TPayload>>, Application, AdvanceTimeSettings, String)Converts a CepStream of point events to a stream.
Public methodStatic memberTumblingWindow<TPayload>(CepStream<TPayload>, TimeSpan)Transforms a stream to a window stream where each member is a CepWindow using the default output policy.
Public methodStatic memberTumblingWindow<TPayload>(CepStream<TPayload>, TimeSpan, HoppingWindowOutputPolicy)Transforms a stream to a window stream where each member is a CepWindow.
Public methodStatic memberTumblingWindow<TPayload>(CepStream<TPayload>, TimeSpan, DateTime)Transforms a stream to a window stream where each member is a CepWindow using the default output policy.
Public methodStatic memberTumblingWindow<TPayload>(CepStream<TPayload>, TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy)Transforms a stream to a window stream where each member is a CepWindow.
Public methodStatic memberTumblingWindow<TPayload>(CepStream<TPayload>, TimeSpan, DateTime, HoppingWindowOutputPolicy)Transforms a stream to a window stream where each member is a CepWindow.
Public methodStatic memberTumblingWindow<TPayload>(CepStream<TPayload>, TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy)Transforms a stream to a window stream where each member is a CepWindow.
Public methodStatic memberUnion<TPayload>Unions two streams together into one stream.
Public methodStatic memberWhere<TPayload>(CepStream<TPayload>, Expression<Func<TPayload, Boolean>>)Filters events from an input stream using a given filter function.
Public methodStatic memberWhere<TInput>(ICepEnumerable<TInput>, Expression<Func<TInput, Boolean>>)Filters events from an enumerable input stream using the specified filter expression.
Top

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.

Any public static (Shared in Visual Basic) members of this type are thread safe. Any instance members are not guaranteed to be thread safe.
Was this page helpful?
(1500 characters remaining)
Thank you for your feedback
Show:
© 2014 Microsoft