次の方法で共有


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

ストリームを変換して、各メンバーが CepWindow であるウィンドウ ストリームにします。ウィンドウは、一定のウィンドウ サイズとホップ サイズの期間によって定義されます。

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

構文

public static CepWindowStream<CepWindow<TPayload>> HoppingWindow<TPayload>(
    this CepStream<TPayload> source,
    TimeSpan windowSize,
    TimeSpan hopSize,
    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 hoppingAgg = from w in inputStream.HoppingWindow(TimeSpan.FromHours(1),
                                                     TimeSpan.FromMinutes(10),
                                                     WindowOutputPolicy.ClipToWindowEnd)
                 select new { sum = w.Sum(e => e.i) };

関連項目

参照

CepStream クラス

HoppingWindow オーバーロード

Microsoft.ComplexEventProcessing.Linq 名前空間