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
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.

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