Export (0) Print
Expand All

CepStream<TPayload> Class

Represents a stream of events from any user specified payload type.

System.Object
  Microsoft.ComplexEventProcessing.Linq.CepStream<TPayload>

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

public sealed class CepStream<TPayload>

Type Parameters

TPayload

The payload type of the event in the stream.

The CepStream<TPayload> type exposes the following members.

  NameDescription
Public methodStatic memberCreate(String)Creates an unbound stream with event payload of type 'TPayload'.
Public methodStatic memberCreate(Uri, EventShape)Creates a bound stream over an input from a given published stream.
Public methodStatic memberCreate(Uri, EventShape, AdvanceTimeSettings) Creates a bound stream for input from a given published stream.
Public methodStatic memberCreate(Application, Uri, EventShape)Creates a bound stream over an input from a given published stream.
Public methodStatic memberCreate(String, Type, Object, EventShape)Creates a bound stream from a given input adapter factory.
Public methodStatic memberCreate(Application, Uri, EventShape, AdvanceTimeSettings)Creates a bound stream for input from a given published stream.
Public methodStatic memberCreate(String, Type, Object, EventShape, AdvanceTimeSettings)Creates a bound stream from a given input adapter factory.
Public methodStatic memberCreate(Application, String, Type, Object, EventShape)Creates a bound stream from a given input adapter factory.
Public methodStatic memberCreate(Application, String, Type, Object, EventShape, AdvanceTimeSettings)Creates a bound stream from a given input adapter factory.
Public methodEquals (Inherited from Object.)
Public methodExtractInputStreamsRetrieves a list with information about input streams from a given stream definition.
Public methodGetHashCode (Inherited from Object.)
Public methodGetType (Inherited from Object.)
Public methodToPublishedStreamQuery(Uri, String, String, EventShape, StreamEventOrder)Creates a query with an output bound to an explicitly named published stream. The output of the query can be consumed through dynamic query composition. Only one query can produce events for a published stream at any given time.
Public methodToPublishedStreamQuery(Uri, Application, String, String, EventShape, StreamEventOrder)Creates a query with an output bound to an explicitly named published stream. The output of the query can be consumed through dynamic query composition. Only one query can produce events for a published stream at any given time.
Public methodToQuery(String, String, EventShape, StreamEventOrder)Creates a query from the stream with an unbound output. All inputs to the query must be bound to adapters, sequences or other queries. The output of the query can be consumed through dynamic query composition only. The application this query will run in is implied by the definition of the stream.
Public methodToQuery(Application, String, String, EventShape, StreamEventOrder)Creates a query from the stream with an unbound output running in the specified application. All inputs to the query must be bound to adapters, sequences or other queries. The output of the query can be consumed through dynamic query composition only.
Public methodToQuery(String, String, Type, Object, EventShape, StreamEventOrder)Creates a query from the stream bound to an output adapter. The output adapter is specified by the type of the adapter factory and the configuration object. The application this query will run in is implied by the definition of the stream.
Public methodToQuery(String, String, Type, Object, EventShape, StreamEventOrder, Boolean)Creates a query from the stream bound to an output adapter. The output adapter is specified by the type of the adapter factory and the configuration object. The application this query will run in is implied by the definition of the stream. The query can be specified to be resilient.
Public methodToQuery(Application, String, String, Type, Object, EventShape, StreamEventOrder)Creates a query from the stream bound to an output adapter running in the specified application. The output adapter is specified by the type of the adapter factory and the configuration object.
Public methodToQuery(Application, String, String, Type, Object, EventShape, StreamEventOrder, Boolean)Creates a query from the stream bound to an output adapter running in the specified application. The output adapter is specified by the type of the adapter factory and the configuration object. The query can be specified to be resilient.
Public methodToString (Inherited from Object.)
Top

  NameDescription
Public Extension MethodAlterEventDuration<TPayload>Changes the duration of the input events. This method does not change the start time of an event. (Defined by CepStream.)
Public Extension MethodAlterEventLifetime<TPayload>Alters the lifetime of the events in the stream. This method can change both the start time and end time of an event. (Defined by CepStream.)
Public Extension MethodClipEventDuration<TSource, TClip> Shortens the lifetime of events in sourceStream to the start time of the next corresponding event in clipStream, matched by matchExpression. (Defined by CepStream.)
Public Extension MethodCountByStartTimeWindow<TPayload>(UInt32)Overloaded. 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. (Defined by CepStream.)
Public Extension MethodCountByStartTimeWindow<TPayload>(UInt32, CountWindowOutputPolicy)Overloaded. 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. (Defined by CepStream.)
Public Extension MethodCountByStartTimeWindow<TPayload>(UInt32, WindowInputPolicy, CountWindowOutputPolicy)Overloaded. 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. (Defined by CepStream.)
Public Extension MethodGroupBy<TPayload, TGroupingKey>(Expression<Func<TPayload, TGroupingKey>>)Overloaded. Partitions the input stream by the specified grouping key. (Defined by CepStream.)
Public Extension MethodGroupBy<TPayload, TGroupingKey, TResult>(Expression<Func<TPayload, TGroupingKey>>, Expression<Func<TPayload, TResult>>)Overloaded. Groups the source stream by the specified key selector functions and projects results using the element selector function. (Defined by CepStream.)
Public Extension MethodHoppingWindow<TPayload>(TimeSpan, TimeSpan)Overloaded. Transforms a stream to a window stream where each member is a CepWindow using the default output policy. (Defined by CepStream.)
Public Extension MethodHoppingWindow<TPayload>(TimeSpan, TimeSpan, DateTime)Overloaded. Transforms a stream to a window stream where each member is a CepWindow using the default output policy. (Defined by CepStream.)
Public Extension MethodHoppingWindow<TPayload>(TimeSpan, TimeSpan, HoppingWindowOutputPolicy)Overloaded. Transforms a stream to a window stream where each member is a CepWindow using the default output policy. (Defined by CepStream.)
Public Extension MethodHoppingWindow<TPayload>(TimeSpan, TimeSpan, DateTime, HoppingWindowOutputPolicy)Overloaded. Transforms a stream to a window stream where each member is a CepWindow. (Defined by CepStream.)
Public Extension MethodHoppingWindow<TPayload>(TimeSpan, TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy)Overloaded. Transforms a stream to a window stream where each member is a CepWindow using the default output policy. (Defined by CepStream.)
Public Extension MethodHoppingWindow<TPayload>(TimeSpan, TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy)Overloaded. The window is defined by constant window size and hop size timespans. (Defined by CepStream.)
Public Extension MethodIsEmpty<TPayload>Performs a left anti-semi-join (LASJ) query on the specified stream. (Defined by CepStream.)
Public Extension MethodJoin<TOuter, TInner, TKey, TResult>Joins the events from the outer stream with events from the inner stream on the given join key. (Defined by CepStream.)
Public Extension MethodSelect<TPayload, TResult>Projects events from input stream using a projections expression. (Defined by CepStream.)
Public Extension MethodSelectMany<TInput, TBind, TResult> Produces a stream based on the cross join of two input streams. (Defined by CepStream.)
Public Extension MethodShiftEventTime<TPayload>(Expression<Func<CepEvent, DateTime>>)Overloaded. Shift event times to the value specified by the shiftExpr parameter. The method does not change event life times. (Defined by CepStream.)
Public Extension MethodShiftEventTime<TPayload>(Expression<Func<CepEvent, TimeSpan>>)Overloaded. Shift event times by the amount specified by the shiftExpr parameter. The value returned may be positive or negative. (Defined by CepStream.)
Public Extension MethodSnapshotWindow<TPayload>()Overloaded. Transforms a stream to a window stream where each member is a CepWindow using the default output policy. (Defined by CepStream.)
Public Extension MethodSnapshotWindow<TPayload>(SnapshotWindowOutputPolicy)Overloaded. Transforms a stream to a window stream where each member is a CepWindow. (Defined by CepStream.)
Public Extension MethodSnapshotWindow<TPayload>(WindowInputPolicy, SnapshotWindowOutputPolicy)Overloaded. Transforms a stream to a window stream where each member is a CepWindow. (Defined by CepStream.)
Public Extension MethodToEdgeEnumerable<TPayload>()Overloaded. Converts a CepStream of edge events to an event sink that implements the IEnumerable interface. (Defined by CepStream.)
Public Extension MethodToEdgeEnumerable<TPayload>(StreamEventOrder)Overloaded. Converts a CepStream of edge events to an event sink that implements the IEnumerable interface. (Defined by CepStream.)
Public Extension MethodToEdgeObservable<TPayload>()Overloaded. Converts a CepStream of edge events to an event sink that implements the IObservable interface. The order of events is FullyOrdered. (Defined by ObservableCepStream.)
Public Extension MethodToEdgeObservable<TPayload>(StreamEventOrder)Overloaded. Converts a CepStream of edge events with the specified event order to an event sink that implements the IObservable interface. (Defined by ObservableCepStream.)
Public Extension MethodToEnumerable<TPayload>()Overloaded. Converts a stream of events to enumerable output by removing event headers and discarding CTI events. (Defined by CepStream.)
Public Extension MethodToEnumerable<TPayload>(StreamEventOrder)Overloaded. Converts a stream of events to enumerable output with the specified event order by removing event headers and discarding CTI events. (Defined by CepStream.)
Public Extension MethodToIntervalEnumerable<TPayload>()Overloaded. Converts a CepStream of interval events to an event sink that implements the IEnumerable interface. The order of events is FullyOrdered. (Defined by CepStream.)
Public Extension MethodToIntervalEnumerable<TPayload>(StreamEventOrder)Overloaded. Converts a CepStream of interval events with the specified event order to an event sink that implements the IEnumerable interface. (Defined by CepStream.)
Public Extension MethodToIntervalObservable<TPayload>()Overloaded. Converts a CepStream of interval events to an event sink that implements the IObservable interface. The order of events is FullyOrdered. (Defined by ObservableCepStream.)
Public Extension MethodToIntervalObservable<TPayload>(StreamEventOrder)Overloaded. Converts a CepStream of interval events with the specified event order to an event sink that implements the IObservable interface. (Defined by ObservableCepStream.)
Public Extension MethodToObservable<TPayload>()Overloaded. Converts a stream of events to observable output by removing event headers and discarding CTI events. (Defined by ObservableCepStream.)
Public Extension MethodToObservable<TPayload>(StreamEventOrder)Overloaded. Converts a stream of events to observable output with the specified event order by removing event headers and discarding CTI events. (Defined by ObservableCepStream.)
Public Extension MethodToPointEnumerable<TPayload>()Overloaded. Converts a CepStream of point events to an event sink that implements the IEnumerable interface. The order of events is FullyOrdered. (Defined by CepStream.)
Public Extension MethodToPointEnumerable<TPayload>(StreamEventOrder)Overloaded. Converts a CepStream of point events with the specified event order to an event sink that implements the IEnumerable interface. (Defined by CepStream.)
Public Extension MethodToPointEventStream<TPayload>Changes the events in an input stream to point events by keeping only the event start times. (Defined by CepStream.)
Public Extension MethodToPointObservable<TPayload>()Overloaded. Converts a CepStream of point events to an event sink that implements the IObservable interface. The order of events is FullyOrdered. (Defined by ObservableCepStream.)
Public Extension MethodToPointObservable<TPayload>(StreamEventOrder)Overloaded. Converts a CepStream of point events with the specified event order to an event sink that implements the IObservable interface. (Defined by ObservableCepStream.)
Public Extension MethodTumblingWindow<TPayload>(TimeSpan)Overloaded. Transforms a stream to a window stream where each member is a CepWindow using the default output policy. (Defined by CepStream.)
Public Extension MethodTumblingWindow<TPayload>(TimeSpan, DateTime)Overloaded. Transforms a stream to a window stream where each member is a CepWindow using the default output policy. (Defined by CepStream.)
Public Extension MethodTumblingWindow<TPayload>(TimeSpan, HoppingWindowOutputPolicy)Overloaded. Transforms a stream to a window stream where each member is a CepWindow. (Defined by CepStream.)
Public Extension MethodTumblingWindow<TPayload>(TimeSpan, DateTime, HoppingWindowOutputPolicy)Overloaded. Transforms a stream to a window stream where each member is a CepWindow. (Defined by CepStream.)
Public Extension MethodTumblingWindow<TPayload>(TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy)Overloaded. Transforms a stream to a window stream where each member is a CepWindow. (Defined by CepStream.)
Public Extension MethodTumblingWindow<TPayload>(TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy)Overloaded. Transforms a stream to a window stream where each member is a CepWindow. (Defined by CepStream.)
Public Extension MethodUnion<TPayload>Unions two streams together into one stream. (Defined by CepStream.)
Public Extension MethodWhere<TPayload>Filters events from an input stream using a given filter function. (Defined by CepStream.)
Top

Before you can write a CEP query, you must provide the appropriate stream definition. This class provides various methods to create a CepStream object.

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