ObservableCepStream Methods
Namespace: Microsoft.ComplexEventProcessing.Linq
Assembly: Microsoft.ComplexEventProcessing.Observable (in Microsoft.ComplexEventProcessing.Observable.dll)
Methods
Name | Description | |
---|---|---|
Select<TInput, TOutput>(ICepObservable<TInput>, Expression<Func<TInput, TOutput>>) | Projects each event of an observable input stream into a new event. |
|
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. |
|
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. |
|
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. |
|
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. |
|
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. |
|
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. |
|
ToObservable<TPayload>(CepStream<TPayload>) | Converts a stream of events to observable output by removing event headers and discarding CTI events. |
|
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. |
|
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. |
|
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. |
|
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. |
|
ToStream<TPayload>(IObservable<EdgeEvent<TPayload>>, Application, AdvanceTimeSettings, String) | Translates an event source that implements the IObservable interface into a CepStream that can be queried. |
|
ToStream<TPayload>(IObservable<IntervalEvent<TPayload>>, Application, AdvanceTimeSettings, String) | Translates an event source that implements the IObservable interface into a CepStream that can be queried. |
|
ToStream<TPayload>(IObservable<PointEvent<TPayload>>, Application, AdvanceTimeSettings, String) | Translates an event source that implements the IObservable interface into a CepStream that can be queried. |
|
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