ToEdgeStream(TInput, TPayload) メソッド
監視可能な入力ストリームをエッジ イベントのストリームに変換し、入力の時間特性を指定します。
名前空間: 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,
string streamName
)
型パラメーター
- TInput
入力の種類。
- TPayload
イベント ペイロードの種類。
パラメーター
- source
型: System. . :: . .IObservable< (Of < ( <'TInput> ) > ) >
監視可能な入力ストリーム。
- application
型: Microsoft.ComplexEventProcessing. . :: . .Application
イベント ソースをホストするアプリケーション インスタンス。このパラメーターは null にはできません。アプリケーションは、Server.Create のいずれかのオーバーロードの呼び出しによって生成された埋め込みサーバーに属している必要があります。
- selector
型: System.Linq.Expressions. . :: . .Expression< (Of < ( <'Func< (Of < ( <'TInput, EdgeEvent< (Of < ( <'TPayload> ) > ) >> ) > ) >> ) > ) >
入力をエッジ イベントのストリームとして再形成する式。
- advanceTimeSettings
型: Microsoft.ComplexEventProcessing. . :: . .AdvanceTimeSettings
入力の時間特性。
- streamName
型: System. . :: . .String
ストリームの名前。
ストリーム名は、AdvanceTimeImportSettings によるストリームからストリームへの CTI イベントの "インポート" をサポートします。これらの設定では、CTI イベントのインポート元となる入力ストリームの名前をユーザーが指定する必要があります。
戻り値
型: Microsoft.ComplexEventProcessing.Linq. . :: . .CepStream< (Of < ( <'TPayload> ) > ) >
エッジ イベントのストリーム。
使用に関するメモ
Visual Basic および C# では、このメソッドを型 IObservable< (Of < ( <'TInput> ) > ) > の任意のオブジェクトのインスタンス メソッドとして呼び出すことができます。このメソッドを呼び出すためにインスタンス メソッドの構文を使う場合は、最初のパラメーターを省略してください。詳細については、「https://msdn.microsoft.com/ja-jp/library/bb384936(v=sql.105)」または「https://msdn.microsoft.com/ja-jp/library/bb383977(v=sql.105)」を参照してください。