次の方法で共有


TumblingWindow(TPayload) メソッド (CepStream(TPayload), TimeSpan, HoppingWindowOutputPolicy)

ストリームを変換して、各メンバーが CepWindow であるウィンドウ ストリームにします。タンブリング ウィンドウとは、ウィンドウ サイズとホップ サイズが同一の特殊なホッピング ウィンドウです。

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

構文

public static CepWindowStream<CepWindow<TPayload>> TumblingWindow<TPayload>(
    this CepStream<TPayload> source,
    TimeSpan windowSize,
    HoppingWindowOutputPolicy outputPolicy
)

型パラメーター

  • TPayload
    入力イベント ペイロードの型。

パラメーター

戻り値

型: Microsoft.ComplexEventProcessing.Linq. . :: . .CepWindowStream< (Of < ( <'CepWindow< (Of < ( <'TPayload> ) > ) >> ) > ) >
集計、順位付け、またはユーザー定義の操作を適用できるウィンドウ ストリーム。

使用に関するメモ

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

説明

詳細については、「イベント ウィンドウの使用」を参照してください。

使用例

var tumblingAgg = from w in inputStream.TumblingWindow(TimeSpan.FromHours(1),
                                                       WindowOutputPolicy.ClipToWindowEnd)
                  select new { sum = w.Sum(e => e.i) };

関連項目

参照

CepStream クラス

TumblingWindow オーバーロード

Microsoft.ComplexEventProcessing.Linq 名前空間