ObservableCepStream Methods

 

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

Methods

Name Description
System_CAPS_pubmethodSystem_CAPS_static Select<TInput, TOutput>(ICepObservable<TInput>, Expression<Func<TInput, TOutput>>)

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

System_CAPS_pubmethodSystem_CAPS_static ToEdgeObservable<TPayload>(CepStream<TPayload>)

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

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

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

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

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

System_CAPS_pubmethodSystem_CAPS_static ToIntervalObservable<TPayload>(CepStream<TPayload>)

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

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

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

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

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

System_CAPS_pubmethodSystem_CAPS_static ToObservable<TPayload>(CepStream<TPayload>)

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

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

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

System_CAPS_pubmethodSystem_CAPS_static ToPointObservable<TPayload>(CepStream<TPayload>)

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

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

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

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

Converts an observable input stream to a stream of point events, and provides the temporal characteristics of the input.

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

Translates an event source that implements the IObservable interface into a CepStream that can be queried.

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

Translates an event source that implements the IObservable interface into a CepStream that can be queried.

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

Translates an event source that implements the IObservable interface into a CepStream that can be queried.

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

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

See Also

ObservableCepStream Class
Microsoft.ComplexEventProcessing.Linq Namespace

Return to top