次の方法で共有


ToStream(TPayload) メソッド (Query)

既存のクエリの出力イベント ストリームにバインドされた新しい入力ストリームを作成します。

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

構文

public static CepStream<TPayload> ToStream<TPayload>(
    this Query query
)

型パラメーター

  • TPayload
    新しいストリームのペイロードの種類。

パラメーター

戻り値

型: Microsoft.ComplexEventProcessing.Linq. . :: . .CepStream< (Of < ( <'TPayload> ) > ) >
新しいクエリの作成に使用できる、CepStream クラスのインスタンス。

使用に関するメモ

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

使用例

Application myApp = server.CreateApplication("MyApp");
var inputstream = CepStream{TPayload}.Create("inputStream", typeof(InputFactory), inConf, EventShape.Point);
var filtered = from e in inputstream
               where e.Value > 25
               select e;
var query = filtered.ToQuery(myApp, "filterQuery", "", typeof(OutputFactory), outConf, EventShape.Point, StreamEventOrder.FullyOrdered);
var filteredStream = query.ToStream{TPayload}();
var validated = from e in filteredStream
                select new
                {
                    SourceId = e.SourceId,
                    Value = e.Value,
                    Status = e.Value > 75 ? false : true
                };
var validationQuery = validated.ToQuery("validationQuery", "", typeof(OutputFactory), outConf2, EventShape.Point, StreamEventOrder.FullyOrdered);

関連項目

参照

DynamicQueryCompositionExtensions クラス

ToStream オーバーロード

Microsoft.ComplexEventProcessing 名前空間