API Support for IQbservable, IQueryable, IQStreamable in StreamInsight

 

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

The following API features support event sources that implement the IQbservable or IQueryable interfaces.

IQueryable Source

Defining inputs from IQueryable source

Define a remote sequence by using one of the following overloads for the DefineEnumerable method of the T:Microsoft.ComplexEventProcessing.Linq.RemoteProvider class.

Retrieving inputs from IQueryable source

Retrieve a remote function that returns a sequence by using one of the following overloads for the GetEnumerable method of the T:Microsoft.ComplexEventProcessing.Linq.RemoteProvider class.

Deploying inputs from IQueryable source

Deploy a remote function that returns a sequence by using one of the following overloads for the Deploy method of the T:Microsoft.ComplexEventProcessing.Linq.RemoteProvider class.

IQbservable Source

Defining inputs from IQbservable source

Define a remote sequence by using one of the following overloads for the DefineObservable method of the T:Microsoft.ComplexEventProcessing.Linq.RemoteProvider class.

Retrieving inputs from IQbservable source

Retrieve a remote function that returns a sequence by using one of the following overloads for the GetObservable method of the T:Microsoft.ComplexEventProcessing.Linq.RemoteProvider class.

Deploying inputs from IQbservable source

Deploy a remote function that returns a sequence by using one of the following overloads for the Deploy method of the T:Microsoft.ComplexEventProcessing.Linq.RemoteProvider class.

IQStreamable Source

Defining inputs from IQStreamable source

Define a remote temporal stream by using one of the following overloads for the DefineStreamable method of the T:Microsoft.ComplexEventProcessing.Linq.RemoteProvider class.

Retrieving inputs from IQStreamable source

Retrieve a remote temporal stream by using one of the following overloads for the GetStreamable method of the T:Microsoft.ComplexEventProcessing.Linq.RemoteProvider class.

Deploying inputs from IQStreamable source

Deploy a remote temporal stream by using one of the following overloads for the Deploy method of the T:Microsoft.ComplexEventProcessing.Linq.RemoteProvider class.

IQbserver Sink

Defining observers from IQbserver Sink

Define a remote observer by using one of the following overloads for the DefineObserver method of the T:Microsoft.ComplexEventProcessing.Linq.RemoteProvider class.

Retrieving observers from IQbserver Sink

Retrieve a remote observer by using one of the following overloads for the GetObserver method of the T:Microsoft.ComplexEventProcessing.Linq.RemoteProvider class.

Deploying observers from IQbserver Sink

Deploy a remote observer by using one of the following overloads for the Deploy method of the T:Microsoft.ComplexEventProcessing.Linq.RemoteProvider class.

IQStreamable Sink

Defining sinks from IQStreamable Sink

Define a remote temporal stream sink by using one of the following overloads for the DefineStreamableSink method of the T:Microsoft.ComplexEventProcessing.Linq.RemoteProvider class.

Retrieving sinks from IQStreamable Sink

Retrieve a remote temporal stream sink by using one of the following overloads for the GetStreamableSink method of the T:Microsoft.ComplexEventProcessing.Linq.RemoteProvider class.

Deploying sinks from IQStreamable Sink

Deploy a remote temporal stream sink by using one of the following overloads for the Deploy method of the T:Microsoft.ComplexEventProcessing.Linq.RemoteProvider class.

A subject is a named, running artifact that enables runtime composition. A subject implements both the IObservable and IObserver interfaces, enabling it to both subscribe to observable sources and accept observer subscriptions. For more information, see StreamInsight Concepts.

The following API features support event sources that implement the Subject interfaces.

The following summarizes the API features in StreamInsight that support Binding, an executable composition over sources (IQbservable, IQueryable, IQStreamable), sinks (IQbserver, IQStreamableSink), or subjects.

To Temporal Stream

From IQueryable:

From IQbservable:

To IQueryable

From IQStreamable:

From IQbservable:

To IQbservable

From IQueryable:

From IQStreamable:

Using Event Sources and Event Sinks (StreamInsight)

Show: