ToStream(TPayload) メソッド (IObservable(PointEvent(TPayload)), Application, AdvanceTimeSettings, String)

IObservable インターフェイスを実装するイベント ソースを、照会できる CepStream に変換します。

名前空間:  Microsoft.ComplexEventProcessing.Linq
アセンブリ:  Microsoft.ComplexEventProcessing.Observable (Microsoft.ComplexEventProcessing.Observable.dll)

構文

public static CepStream<TPayload> ToStream<TPayload>(
    this IObservable<PointEvent<TPayload>> source,
    Application application,
    AdvanceTimeSettings advanceTimeSettings,
    string streamName
)

型パラメーター

• TPayload
  イベント ペイロードの種類。

パラメーター

• source
  型: System. . :: . .IObservable< (Of < ( <'PointEvent< (Of < ( <'TPayload> ) > ) >> ) > ) >
  監視可能な入力ストリーム。

• application
  型: Microsoft.ComplexEventProcessing. . :: . .Application
  イベント ソースをホストするアプリケーション インスタンス。このパラメーターは null にはできません。アプリケーションは、Server.Create のいずれかのオーバーロードの呼び出しによって生成された埋め込みサーバーに属している必要があります。

• advanceTimeSettings
  型: Microsoft.ComplexEventProcessing. . :: . .AdvanceTimeSettings
  入力の時間特性。

• streamName
  型: System. . :: . .String
  ストリームの名前。
  ストリーム名は、AdvanceTimeImportSettings によるストリームからストリームへの CTI イベントの "インポート" をサポートします。これらの設定では、CTI イベントのインポート元となる入力ストリームの名前をユーザーが指定する必要があります。

戻り値

型: Microsoft.ComplexEventProcessing.Linq. . :: . .CepStream< (Of < ( <'TPayload> ) > ) >
クエリの構成に使用できる監視可能なイベント ソースのストリーム定義。

使用に関するメモ

Visual Basic および C# では、このメソッドを型 IObservable< (Of < ( <'PointEvent< (Of < ( <'TPayload> ) > ) >> ) > ) > の任意のオブジェクトのインスタンス メソッドとして呼び出すことができます。このメソッドを呼び出すためにインスタンス メソッドの構文を使う場合は、最初のパラメーターを省略してください。詳細については、「https://msdn.microsoft.com/ja-jp/library/bb384936(v=sql.105)」または「https://msdn.microsoft.com/ja-jp/library/bb383977(v=sql.105)」を参照してください。

関連項目

参照

ObservableCepStream クラス

ToStream オーバーロード

Microsoft.ComplexEventProcessing.Linq 名前空間