StreamInsight 對於 IQbservable、IQueryable、IQStreamable 介面的 API 支援

 

此主題將摘要說明 StreamInsight 中支援實作 IQbservableIQueryable 介面之事件來源和接收的 API 功能。

對於 IQbservable/IQueryable/IQStreamable 來源的 API 支援

下列 API 功能支援實作 IQbservableIQueryable 介面的事件來源。

IQueryable 來源

定義來自 IQueryable 來源的輸入

使用 T:Microsoft.ComplexEventProcessing.Linq.RemoteProvider 類別之 DefineEnumerable 方法的下列其中一個多載,來定義遠端序列。

從 IQueryable 來源擷取輸入

藉由使用 T:Microsoft.ComplexEventProcessing.Linq.RemoteProvider 類別之 GetEnumerable 方法的下列其中一個多載,擷取可傳回序列的遠端函數。

部署 IQueryable 來源的輸入

藉由使用 T:Microsoft.ComplexEventProcessing.Linq.RemoteProvider 類別之 Deploy 方法的下列其中一個多載,部署可傳回序列的遠端函數。

IQbservable 來源

定義來自 IQbservable 來源的輸入

使用 T:Microsoft.ComplexEventProcessing.Linq.RemoteProvider 類別之 DefineObservable 方法的下列其中一個多載,來定義遠端序列。

從 IQbservable 來源擷取輸入

藉由使用 T:Microsoft.ComplexEventProcessing.Linq.RemoteProvider 類別之 GetObservable 方法的下列其中一個多載,擷取可傳回序列的遠端函數。

部署 IQbservable 來源的輸入

藉由使用 T:Microsoft.ComplexEventProcessing.Linq.RemoteProvider 類別之 Deploy 方法的下列其中一個多載,部署可傳回序列的遠端函數。

IQStreamable 來源

定義來自 IQStreamable 來源的輸入

使用 T:Microsoft.ComplexEventProcessing.Linq.RemoteProvider 類別之 DefineStreamable 方法的下列其中一個多載,來定義遠端暫時資料流。

從 IQStreamable 來源擷取輸入

使用 T:Microsoft.ComplexEventProcessing.Linq.RemoteProvider 類別之 GetStreamable 方法的下列其中一個多載,來擷取遠端暫時資料流。

部署 IQStreamable 來源的輸入

使用 T:Microsoft.ComplexEventProcessing.Linq.RemoteProvider 類別之 Deploy 方法的下列其中一個多載,來部署遠端暫時資料流。

對於 IQbserver 和 IQStreamable 接收的 API 支援

IQbserver 接收

定義來自 IQbserver 接收的觀察器

使用 T:Microsoft.ComplexEventProcessing.Linq.RemoteProvider 類別之 DefineObserver 方法的下列其中一個多載,來定義遠端觀察器。

從 IQbserver 接收擷取觀察器

使用 T:Microsoft.ComplexEventProcessing.Linq.RemoteProvider 類別之 GetObserver 方法的下列其中一個多載,來擷取遠端觀察器。

部署 IQbserver 接收的觀察器

使用 T:Microsoft.ComplexEventProcessing.Linq.RemoteProvider 類別之 Deploy 方法的下列其中一個多載,來部署遠端觀察器。

IQStreamable 接收

定義來自 IQStreamable 接收的接收

使用 T:Microsoft.ComplexEventProcessing.Linq.RemoteProvider 類別之 DefineStreamableSink 方法的下列其中一個多載,來定義遠端暫時資料流接收。

從 IQStreamable 接收擷取接收

使用 T:Microsoft.ComplexEventProcessing.Linq.RemoteProvider 類別之 GetStreamableSink 方法的下列其中一個多載,來擷取遠端暫時資料流接收。

部署 IQStreamable 接收的接收

使用 T:Microsoft.ComplexEventProcessing.Linq.RemoteProvider 類別之 Deploy 方法的下列其中一個多載,來部署遠端暫時資料流接收。

對於主旨的 API 支援

*「主旨」*是啟用執行階段撰寫的具名、執行中成品。 主旨會實作 IObservableIObserver 介面,讓它能夠訂閱可觀察來源以及接受觀察器訂閱。 如需詳細資訊,請參閱<StreamInsight 概念>。

下列 API 功能支援實作 Subject 介面的事件來源。

對於繫結的 API 支援

以下摘要說明 StreamInsight 中支援*「繫結」*的 API 功能,繫結是透過來源 (IQbservableIQueryableIQStreamable)、接收 (IQbserverIQStreamableSink) 或主旨的可執行檔撰寫。

對於 Bridge 方法的 API 支援

至暫時資料流

IQueryable

IQbservable

至 IQueryable

IQStreamable

IQbservable

至 IQbservable

IQueryable

IQStreamable

請參閱

使用事件來源和事件接收 (StreamInsight)