Export (0) Print
Expand All

API Support for IObservable and IEnumerable in StreamInsight

This topic summarizes the API features in StreamInsight that support event sources and sinks that implement the IObservable or IEnumerable interfaces.

The following API features support event sources that implement the IObservable or IEnumerable interfaces.

Creating inputs

Creating bound inputs

Creating inputs from observable input

Creating inputs from enumerable input

Describing the temporal characteristics

Describe the temporal characteristics of the source data by using one of the following helpers on the AdvanceTimeSettings class.

Mapping input to point, interval, and edge events

Map input data to point, interval or edge events by using the following methods in an expression passed to an overload of the ToStream method.

Mapping input to point events

Map input data to point events and the corresponding CTI events by using the following methods of the PointEvent or PointEvent<TPayload> class in an expression passed to an overload of the ToStream method.

Mapping input to interval events

Map input data to interval events and the corresponding CTI events by using the following methods of the IntervalEvent or IntervalEvent<TPayload> class in an expression passed to an overload of the ToStream method.

Creating edge events

The following API features support event sinks that implement the IObservable or IEnumerable interfaces.

Creating outputs

Mapping output

Extended interfaces for event sinks

The methods described above for creating and filtering output return event sinks that implement interfaces that extend the base IObservable and IEnumerable interfaces. In particular, the extended interfaces let you provide a query name for debugging purposes.

Was this page helpful?
(1500 characters remaining)
Thank you for your feedback

Community Additions

ADD
Show:
© 2015 Microsoft