ObservableCepStream.ToEdgeStream<TInput, TPayload> 方法 (IObservable<TInput>, Application, Expression<Func<TInput, EdgeEvent<TPayload>>>, AdvanceTimeSettings, String)

 

將可觀察輸入資料流轉換為邊緣事件資料流,並提供暫時的輸入特性。

命名空間:   Microsoft.ComplexEventProcessing.Linq
組件:  Microsoft.ComplexEventProcessing.Observable (在 Microsoft.ComplexEventProcessing.Observable.dll 中)

public static CepStream<TPayload> ToEdgeStream<TInput, TPayload>(
	this IObservable<TInput> source,
	Application application,
	Expression<Func<TInput, EdgeEvent<TPayload>>> selector,
	AdvanceTimeSettings advanceTimeSettings = null,
	string streamName = null
)

參數

source

可觀察輸入資料流。

application

主控事件來源的應用程式執行個體。 此參數不可以是 null。 應用程式必須屬於透過呼叫其中一個 Server.Create 多載所產生的內嵌伺服器。

selector

將輸入的外觀重新安排為邊緣事件資料流的運算式。

advanceTimeSettings

暫時的輸入特性。

streamName

資料流的名稱。

資料流名稱支援使用 AdvanceTimeImportSettings 在資料流之間「匯入」CTI 事件。 這些設定需要使用者指出做為匯入 CTI 事件之來源的輸入資料流名稱。

傳回值

Type: Microsoft.ComplexEventProcessing.Linq.CepStream<TPayload>

邊緣事件的資料流。

類型參數

TInput

輸入的類型。

TPayload

事件裝載的類型。

回到頁首
顯示: