Share via

CepStream<TPayload> Class

  • Article

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

Inheritance Hierarchy

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

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

Syntax

public sealed class CepStream<TPayload>

Type Parameters

  • TPayload
    Payload type of the event in the stream.

The CepStream<TPayload> type exposes the following members.

Methods

  Name Description
Public methodStatic member Create(String) Creates an unbound stream with event payload of type 'TPayload'.
Public methodStatic member Create(Uri, EventShape) Creates a bound stream over an input from a given published stream.
Public methodStatic member Create(Uri, EventShape, AdvanceTimeSettings) Creates a bound stream for input from a given published stream.
Public methodStatic member Create(Application, Uri, EventShape) Creates a bound stream over an input from a given published stream.
Public methodStatic member Create(String, Type, Object, EventShape) Creates a bound stream from a given input adapter factory.
Public methodStatic member Create(Application, Uri, EventShape, AdvanceTimeSettings) Creates a bound stream for input from a given published stream.
Public methodStatic member Create(String, Type, Object, EventShape, AdvanceTimeSettings) Creates a bound stream from a given input adapter factory.
Public methodStatic member Create(Application, String, Type, Object, EventShape) Creates a bound stream from a given input adapter factory.
Public methodStatic member Create(Application, String, Type, Object, EventShape, AdvanceTimeSettings) Creates a bound stream from a given input adapter factory.
Public method Equals (Inherited from Object.)
Public method ExtractInputStreams Retrieves a list with information about input streams from a given stream definition.
Protected method Finalize (Inherited from Object.)
Public method GetHashCode (Inherited from Object.)
Public method GetType (Inherited from Object.)
Protected method MemberwiseClone (Inherited from Object.)
Public method ToPublishedStreamQuery(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 method ToPublishedStreamQuery(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 method ToQuery(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 method ToQuery(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 method ToQuery(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 method ToQuery(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 method ToQuery(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 method ToQuery(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 method ToString (Inherited from Object.)

Top

Extension Methods

  Name Description
Public Extension Method AlterEventDuration<TPayload> Changes the duration of the input events. This method does not change the start time of an event. (Defined by CepStream.)
Public Extension Method AlterEventLifetime<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 Method ClipEventDuration<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 Method CountByStartTimeWindow<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 Method CountByStartTimeWindow<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 Method CountByStartTimeWindow<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 Method GroupBy<TPayload, TGroupingKey>(Expression<Func<TPayload, TGroupingKey>>) Overloaded. Partitions the input stream by the specified grouping key. (Defined by CepStream.)
Public Extension Method GroupBy<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 Method HoppingWindow<TPayload>(TimeSpan, TimeSpan) Overloaded. Transforms a stream to a window stream where each member is a CepWindow using the default output policy. The window is defined by the constant window size and hop size timespans. (Defined by CepStream.)
Public Extension Method HoppingWindow<TPayload>(TimeSpan, TimeSpan, DateTime) Overloaded. Transforms a stream to a window stream where each member is a CepWindow using the default output policy. The window is defined by constant window size and hop size timespans. You can also provide an alignment time as a reference for the starting point for the window. (Defined by CepStream.)
Public Extension Method HoppingWindow<TPayload>(TimeSpan, TimeSpan, HoppingWindowOutputPolicy) Overloaded. Transforms a stream to a window stream where each member is a CepWindow. The window is defined by the constant window size and hop size timespans. (Defined by CepStream.)
Public Extension Method HoppingWindow<TPayload>(TimeSpan, TimeSpan, DateTime, HoppingWindowOutputPolicy) Overloaded. Transforms a stream to a window stream where each member is a CepWindow. The window is defined by constant window size and hop size timespans. You can also provide an alignment time as a reference for the starting point for the window. (Defined by CepStream.)
Public Extension Method HoppingWindow<TPayload>(TimeSpan, TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy) Overloaded. Transforms a stream to a window stream where each member is a CepWindow. The window is defined by the constant window size and hop size timespans. You can also provide an alignment time as a reference for the starting point for the window. (Defined by CepStream.)
Public Extension Method HoppingWindow<TPayload>(TimeSpan, TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy) Overloaded. The window is defined by constant window size and hop size timespans. You can also provide an alignment time as a reference for the starting point of the window. (Defined by CepStream.)
Public Extension Method IsEmpty<TPayload> Function used in queries to indicate a left anti-semi-join (LASJ). (Defined by CepStream.)
Public Extension Method Join<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 Method Select<TPayload, TResult> Projects events from input stream using a projections expression. (Defined by CepStream.)
Public Extension Method SelectMany<TInput, TBind, TResult> Produces a stream based on the cross join of two input streams. (Defined by CepStream.)
Public Extension Method ShiftEventTime<TPayload>(Expression<Func<CepEvent, DateTime>>) Overloaded. Shifts the event start time to a new time stamp without changing the lifetime. (Defined by CepStream.)
Public Extension Method ShiftEventTime<TPayload>(Expression<Func<CepEvent, TimeSpan>>) Overloaded. Shifts the event start time by the specified timespan without changing the lifetime. (Defined by CepStream.)
Public Extension Method SnapshotWindow<TPayload>() Overloaded. Transforms a stream to a window stream where each member is a CepWindow using the default output policy. Each window is a snapshot window that is defined by the closest event endpoints in the stream. (Defined by CepStream.)
Public Extension Method SnapshotWindow<TPayload>(SnapshotWindowOutputPolicy) Overloaded. Transforms a stream to a window stream where each member is a CepWindow. Each window is a snapshot window that is defined by the closest event endpoints in the stream. (Defined by CepStream.)
Public Extension Method SnapshotWindow<TPayload>(WindowInputPolicy, SnapshotWindowOutputPolicy) Overloaded. Transforms a stream to a window stream where each member is a CepWindow. Each window is a snapshot window that is defined by the closest event endpoints in the stream. (Defined by CepStream.)
Public Extension Method ToEdgeEnumerable<TPayload>() Overloaded. Converts a CepStream of edge events to an event sink that implements the IEnumerable interface. The order of events is FullyOrdered. (Defined by CepStream.)
Public Extension Method ToEdgeEnumerable<TPayload>(StreamEventOrder) Overloaded. Converts a CepStream of edge events with the specified event order to an event sink that implements the IEnumerable interface. (Defined by CepStream.)
Public Extension Method ToEdgeObservable<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 Method ToEdgeObservable<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 Method ToEnumerable<TPayload>() Overloaded. Converts a stream of events to enumerable output by removing event headers and discarding CTI events. (Defined by CepStream.)
Public Extension Method ToEnumerable<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 Method ToIntervalEnumerable<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 Method ToIntervalEnumerable<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 Method ToIntervalObservable<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 Method ToIntervalObservable<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 Method ToObservable<TPayload>() Overloaded. Converts a stream of events to observable output by removing event headers and discarding CTI events. (Defined by ObservableCepStream.)
Public Extension Method ToObservable<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 Method ToPointEnumerable<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 Method ToPointEnumerable<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 Method ToPointEventStream<TPayload> Changes the events in an input stream to point events by keeping only the event start times. (Defined by CepStream.)
Public Extension Method ToPointObservable<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 Method ToPointObservable<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 Method TumblingWindow<TPayload>(TimeSpan) Overloaded. Transforms a stream to a window stream where each member is a CepWindow using the default output policy. A tumbling window is a special kind of hopping window where window size and hop size are the same. (Defined by CepStream.)
Public Extension Method TumblingWindow<TPayload>(TimeSpan, DateTime) Overloaded. Transforms a stream to a window stream where each member is a CepWindow using the default output policy. A tumbling window is a special kind of hopping window where window size and hop size are the same. You can also provide an alignment time as a reference for the starting point of the window. (Defined by CepStream.)
Public Extension Method TumblingWindow<TPayload>(TimeSpan, HoppingWindowOutputPolicy) Overloaded. Transforms a stream to a window stream where each member is a CepWindow. A tumbling window is a special kind of hopping window where window size and hop size are the same. (Defined by CepStream.)
Public Extension Method TumblingWindow<TPayload>(TimeSpan, DateTime, HoppingWindowOutputPolicy) Overloaded. Transforms a stream to a window stream where each member is a CepWindow. A tumbling window is a special kind of hopping window where window size and hop size are the same. You can also provide an alignment time as a reference for the starting point of the window. (Defined by CepStream.)
Public Extension Method TumblingWindow<TPayload>(TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy) Overloaded. Transforms a stream to a window stream where each member is a CepWindow. A tumbling window is a special kind of hopping window where window size and hop size are the same. You can also provide an alignment time as a reference for the starting point of the window. (Defined by CepStream.)
Public Extension Method TumblingWindow<TPayload>(TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy) Overloaded. Transforms a stream to a window stream where each member is a CepWindow. A tumbling window is a special kind of hopping window where window size and hop size are the same. You can also provide an alignment time as a reference for the starting point of the window. (Defined by CepStream.)
Public Extension Method Union<TPayload> Unions two streams together into one stream. (Defined by CepStream.)
Public Extension Method Where<TPayload> Filters events from an input stream using a given filter function. (Defined by CepStream.)

Top

Remarks

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

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

Reference

Microsoft.ComplexEventProcessing.Linq Namespace