CepStream<TPayload> Class
Represents a stream of events from any user specified payload type.
Namespace: Microsoft.ComplexEventProcessing.Linq
Assembly: Microsoft.ComplexEventProcessing (in Microsoft.ComplexEventProcessing.dll)
Inheritance Hierarchy
System.Object
Microsoft.ComplexEventProcessing.Linq.CepStream<TPayload>
Syntax
public sealed class CepStream<TPayload>
generic<typename TPayload>
public ref class CepStream sealed
[<Sealed>]
type CepStream<'TPayload> = class end
Public NotInheritable Class CepStream(Of TPayload)
Type Parameters
- TPayload
The payload type of the event in the stream.
Methods
| Name | Description | |
|---|---|---|
.jpeg "System_CAPS_pubmethod") .jpeg "System_CAPS_static") |
Create(Application, String, Type, Object, EventShape) | Creates a bound stream from a given input adapter factory. |
|
Create(Application, String, Type, Object, EventShape, AdvanceTimeSettings) | Creates a bound stream from a given input adapter factory. |
|
Create(Application, Uri, EventShape) | Creates a bound stream over an input from a given published stream. |
|
Create(Application, Uri, EventShape, AdvanceTimeSettings) | Creates a bound stream for input from a given published stream. |
|
Create(String) | Creates an unbound stream with event payload of type 'TPayload'. |
|
Create(String, Type, Object, EventShape) | Creates a bound stream from a given input adapter factory. |
|
Create(String, Type, Object, EventShape, AdvanceTimeSettings) | Creates a bound stream from a given input adapter factory. |
|
Create(Uri, EventShape) | Creates a bound stream over an input from a given published stream. |
|
Create(Uri, EventShape, AdvanceTimeSettings) | Creates a bound stream for input from a given published stream. |
|
Equals(Object) | (Inherited from Object.) |
|
ExtractInputStreams() | Retrieves a list with information about input streams from a given stream definition. |
|
GetHashCode() | (Inherited from Object.) |
|
GetType() | (Inherited from Object.) |
|
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. |
|
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. |
|
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. |
|
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. |
|
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. |
|
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. |
|
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. |
|
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. |
|
ToString() | (Inherited from Object.) |
Extension Methods
| Name | Description | |
|---|---|---|
|
AlterEventDuration<TPayload>(Expression<Func<CepEvent<TPayload>, TimeSpan>>) | Changes the duration of the input events. This method does not change the start time of an event.(Defined by CepStream.) |
|
AlterEventLifetime<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.(Defined by CepStream.) |
|
ClipEventDuration<TSource, TClip>(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. (Defined by CepStream.) |
|
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.) |
|
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.) |
|
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.) |
|
GroupBy<TPayload, TGroupingKey>(Expression<Func<TPayload, TGroupingKey>>) | Overloaded. Partitions the input stream by the specified grouping key.(Defined by CepStream.) |
|
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.) |
|
HoppingWindow<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.) |
|
HoppingWindow<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.) |
|
HoppingWindow<TPayload>(TimeSpan, TimeSpan, DateTime, HoppingWindowOutputPolicy) | Overloaded. Transforms a stream to a window stream where each member is a CepWindow.(Defined by CepStream.) |
|
HoppingWindow<TPayload>(TimeSpan, TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy) | Overloaded. The window is defined by constant window size and hop size timespans.(Defined by CepStream.) |
|
HoppingWindow<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.) |
|
HoppingWindow<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.) |
|
IsEmpty<TPayload>() | Performs a left anti-semi-join (LASJ) query on the specified stream.(Defined by CepStream.) |
|
Join<TOuter, TInner, TKey, TResult>(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.(Defined by CepStream.) |
|
Select<TPayload, TResult>(Expression<Func<TPayload, TResult>>) | Overloaded. Projects events from input stream using a projections expression.(Defined by CepStream.) |
|
SelectMany<TInput, TBind, TResult>(Expression<Func<CepStream<TInput>, CepStream<TBind>>>, Expression<Func<TInput, TBind, TResult>>) | Overloaded. Produces a stream based on the cross join of two input streams. (Defined by CepStream.) |
|
ShiftEventTime<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.) |
|
ShiftEventTime<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.) |
|
SnapshotWindow<TPayload>() | Overloaded. Transforms a stream to a window stream where each member is a CepWindow using the default output policy.(Defined by CepStream.) |
|
SnapshotWindow<TPayload>(SnapshotWindowOutputPolicy) | Overloaded. Transforms a stream to a window stream where each member is a CepWindow.(Defined by CepStream.) |
|
SnapshotWindow<TPayload>(WindowInputPolicy, SnapshotWindowOutputPolicy) | Overloaded. Transforms a stream to a window stream where each member is a CepWindow.(Defined by CepStream.) |
|
ToEdgeEnumerable<TPayload>() | Overloaded. Converts a CepStream of edge events to an event sink that implements the IEnumerable interface.(Defined by CepStream.) |
|
ToEdgeEnumerable<TPayload>(StreamEventOrder) | Overloaded. Converts a CepStream of edge events to an event sink that implements the IEnumerable interface.(Defined by CepStream.) |
|
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.) |
|
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.) |
|
ToEnumerable<TPayload>() | Overloaded. Converts a stream of events to enumerable output by removing event headers and discarding CTI events.(Defined by CepStream.) |
|
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.) |
|
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.) |
|
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.) |
|
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.) |
|
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.) |
|
ToObservable<TPayload>() | Overloaded. Converts a stream of events to observable output by removing event headers and discarding CTI events.(Defined by ObservableCepStream.) |
|
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.) |
|
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.) |
|
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.) |
|
ToPointEventStream<TPayload>() | Changes the events in an input stream to point events by keeping only the event start times.(Defined by CepStream.) |
|
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.) |
|
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.) |
|
TumblingWindow<TPayload>(TimeSpan) | Overloaded. Transforms a stream to a window stream where each member is a CepWindow using the default output policy.(Defined by CepStream.) |
|
TumblingWindow<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.) |
|
TumblingWindow<TPayload>(TimeSpan, DateTime, HoppingWindowOutputPolicy) | Overloaded. Transforms a stream to a window stream where each member is a CepWindow.(Defined by CepStream.) |
|
TumblingWindow<TPayload>(TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy) | Overloaded. Transforms a stream to a window stream where each member is a CepWindow.(Defined by CepStream.) |
|
TumblingWindow<TPayload>(TimeSpan, HoppingWindowOutputPolicy) | Overloaded. Transforms a stream to a window stream where each member is a CepWindow.(Defined by CepStream.) |
|
TumblingWindow<TPayload>(TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy) | Overloaded. Transforms a stream to a window stream where each member is a CepWindow.(Defined by CepStream.) |
|
Union<TPayload>(CepStream<TPayload>) | Unions two streams together into one stream.(Defined by CepStream.) |
|
Where<TPayload>(Expression<Func<TPayload, Boolean>>) | Overloaded. Filters events from an input stream using a given filter function.(Defined by CepStream.) |
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
Microsoft.ComplexEventProcessing.Linq Namespace
Return to top