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)

System.Object
  Microsoft.ComplexEventProcessing.Linq.ObservableCepStream

public static class ObservableCepStream

NameDescription
System_CAPS_pubmethodSystem_CAPS_staticSelect<TInput, TOutput>(ICepObservable<TInput>, Expression<Func<TInput, TOutput>>)

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

System_CAPS_pubmethodSystem_CAPS_staticToEdgeObservable<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_staticToEdgeObservable<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_staticToEdgeStream<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_staticToIntervalObservable<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_staticToIntervalObservable<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_staticToIntervalStream<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_staticToObservable<TPayload>(CepStream<TPayload>)

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

System_CAPS_pubmethodSystem_CAPS_staticToObservable<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_staticToPointObservable<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_staticToPointObservable<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_staticToPointStream<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_staticToStream<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_staticToStream<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_staticToStream<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_staticWhere<TInput>(ICepObservable<TInput>, Expression<Func<TInput, Boolean>>)

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

Any public static (Shared in Visual Basic) members of this type are thread safe. Any instance members are not guaranteed to be thread safe.

Return to top
Show: