ObservableCepStream Class

Provides support for event sinks that implement the IObservable interface.

Inheritance Hierarchy

System.Object
  Microsoft.ComplexEventProcessing.Linq.ObservableCepStream

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

Syntax

public static class ObservableCepStream

The ObservableCepStream type exposes the following members.

Methods

	Name	Description
	Select<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>	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>	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>	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>	Filters events from an observable input stream using the specified filter expression.

Top

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

Reference

Microsoft.ComplexEventProcessing.Linq Namespace