ObservableCepStream Class
Provides support for event sinks that implement the IObservable interface.
Namespace: Microsoft.ComplexEventProcessing.Linq
Assembly: Microsoft.ComplexEventProcessing.Observable (in Microsoft.ComplexEventProcessing.Observable.dll)
Inheritance Hierarchy
System.Object
Microsoft.ComplexEventProcessing.Linq.ObservableCepStream
Syntax
public static class ObservableCepStream
[ExtensionAttribute]
public ref class ObservableCepStream abstract sealed
[<AbstractClass>]
[<Sealed>]
type ObservableCepStream = class end
<ExtensionAttribute>
Public NotInheritable Class ObservableCepStream
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. |
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