.gif "パブリック メソッド") .gif "静的メンバー") |
AlterEventDuration< (Of < <' (TPayload> ) > > ) |
入力イベントの実行時間を変更します。このメソッドでは、イベントの開始時刻は変更されません。 |
|
AlterEventLifetime< (Of < <' (TPayload> ) > > ) |
ストリーム内のイベントの有効期間を変更します。このメソッドでは、イベントの開始時刻と終了時刻の両方を変更できます。 |
|
ClipEventDuration< (Of < <' (TSource, TClip> ) > > ) |
sourceStream 内のイベントの有効期間を、matchExpression と一致する clipStream 内にある次の対応するイベントの開始時刻に短縮します。 |
|
CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), UInt32) |
指定した数の一意のイベント開始時刻に基づいて、既定の出力ポリシーを使用して入力ストリームのイベントをイベントのウィンドウにグループ化します。異なる時刻に開始される新しいイベントが到着すると、ウィンドウはスライドします。 |
|
CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), UInt32, CountWindowOutputPolicy) |
指定した数の一意のイベント開始時刻に基づいて、入力ストリームのイベントをイベントのウィンドウにグループ化します。異なる時刻に開始される新しいイベントが到着すると、ウィンドウはスライドします。 |
|
CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), UInt32, WindowInputPolicy, CountWindowOutputPolicy) |
指定した数の一意のイベント開始時刻に基づいて、入力ストリームのイベントをイベントのウィンドウにグループ化します。異なる時刻に開始される新しいイベントが到着すると、ウィンドウはスライドします。 |
|
GroupBy< (Of < <' (TPayload, TGroupingKey> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TGroupingKey> ) > > )> ) > > )) |
指定されたグループ化キーによって入力ストリームをパーティション分割します。 |
|
GroupBy< (Of < <' (TPayload, TGroupingKey, TResult> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TGroupingKey> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TResult> ) > > )> ) > > )) |
指定されたキー セレクター関数でソース ストリームをグループ化し、要素セレクター関数を使用して結果を射影します。 |
|
HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan) |
既定の出力ポリシーでストリームを変換して、各メンバーが CepWindow であるウィンドウ ストリームにします。ウィンドウは、一定のウィンドウ サイズとホップ サイズの期間によって定義されます。 |
|
HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, HoppingWindowOutputPolicy) |
ストリームを変換して、各メンバーが CepWindow であるウィンドウ ストリームにします。ウィンドウは、一定のウィンドウ サイズとホップ サイズの期間によって定義されます。 |
|
HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, DateTime) |
既定の出力ポリシーでストリームを変換して、各メンバーが CepWindow であるウィンドウ ストリームにします。ウィンドウは、一定のウィンドウ サイズとホップ サイズの期間によって定義されます。ウィンドウの開始位置の参照として、配置の時刻を指定することもできます。 |
|
HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy) |
ストリームを変換して、各メンバーが CepWindow であるウィンドウ ストリームにします。ウィンドウは、一定のウィンドウ サイズとホップ サイズの期間によって定義されます。ウィンドウの開始位置の参照として、配置の時刻を指定することもできます。 |
|
HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, DateTime, HoppingWindowOutputPolicy) |
ストリームを変換して、各メンバーが CepWindow であるウィンドウ ストリームにします。ウィンドウは、一定のウィンドウ サイズとホップ サイズの期間によって定義されます。ウィンドウの開始位置の参照として、配置の時刻を指定することもできます。 |
|
HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy) |
ウィンドウは、一定のウィンドウ サイズとホップ サイズの期間によって定義されます。ウィンドウの開始位置の参照として、配置の時刻を指定することもできます。 |
|
IsEmpty< (Of < <' (TPayload> ) > > ) |
Left Anti Semi Join (LASJ) を示すためにクエリ内で使用される関数です。 |
|
Join< (Of < <' (TOuter, TInner, TKey, TResult> ) > > ) |
指定された結合キーで、外部ストリームのイベントを内部ストリームのイベントと結合します。 |
|
OrderBy< (Of < <' (TPayload, TOrderKey> ) > > ) |
入力ストリームを rankSelector で並べ替えます。 |
|
OrderByDescending< (Of < <' (TPayload, TOrderKey> ) > > ) |
入力ストリームを rankSelector の降順で並べ替えます。 |
|
Scan< (Of < <' (TInputEvent, TInputPayload, TOutputPayload> ) > > ) |
ユーザー定義のストリーム演算子を使用して入力ストリームをスキャンします。 |
|
Select< (Of < <' (TInput, TResult> ) > > )(CepOrderedStream< (Of < <' (TInput> ) > > ), Expression< (Of < <' (Func< (Of < <' (TInput, TResult> ) > > )> ) > > )) |
順序付けされたストリームが指定されている場合、このメソッドは、順位付けに使用できる順序付けされたストリームを生成します。 |
|
Select< (Of < <' (TPayload, TResult> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TResult> ) > > )> ) > > )) |
射影式を使用して入力ストリームからイベントを射影します。 |
|
Select< (Of < <' (TInput, TResult> ) > > )(CepWindowStream< (Of < <' (CepWindow< (Of < <' (TInput> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepWindow< (Of < <' (TInput> ) > > ), TResult> ) > > )> ) > > )) |
指定されたマッピング式に基づいて、ウィンドウ ストリームを 1 つのストリームにマップします。 |
|
Select< (Of < <' (TInput, TOutput> ) > > )(ICepEnumerable< (Of < <' (TInput> ) > > ), Expression< (Of < <' (Func< (Of < <' (TInput, TOutput> ) > > )> ) > > )) |
列挙可能な入力ストリームの各イベントを新しいイベントに射影します。 |
|
SelectMany< (Of < <' (TInput, TResult> ) > > )(CepWindowStream< (Of < <' (CepWindow< (Of < <' (TInput> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepWindow< (Of < <' (TInput> ) > > ), CepWindow< (Of < <' (TInput> ) > > )> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepWindow< (Of < <' (TInput> ) > > ), TInput, TResult> ) > > )> ) > > )) |
ウィンドウ ストリームに対して ORDER BY 操作をサポートします。 |
|
SelectMany< (Of < <' (TInput, TBind, TResult> ) > > )(CepStream< (Of < <' (TInput> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepStream< (Of < <' (TInput> ) > > ), CepStream< (Of < <' (TBind> ) > > )> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (TInput, TBind, TResult> ) > > )> ) > > )) |
2 つの入力ストリームのクロス結合に基づいて、1 つのストリームを生成します。 |
|
SelectMany< (Of < <' (TInput, TGroupingKey, TBind, TResult> ) > > )(CepGroupingStreams< (Of < <' (TInput, TGroupingKey> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepStream< (Of < <' (TInput> ) > > ), CepStream< (Of < <' (TBind> ) > > )> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (IKey< (Of < <' (TGroupingKey> ) > > ), TBind, TResult> ) > > )> ) > > )) |
"グループ化と適用" に対するクエリ ロジックの追加をサポートします。 |
|
SelectMany< (Of < <' (TInput, TGroupingKey, TBind, TResult> ) > > )(CepGroupingStreams< (Of < <' (TInput, TGroupingKey> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepStream< (Of < <' (TInput> ) > > ), CepWindowStream< (Of < <' (TBind> ) > > )> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (IKey< (Of < <' (TGroupingKey> ) > > ), TBind, TResult> ) > > )> ) > > )) |
2 つの入力ストリームのクロス結合に基づいて、1 つのストリームを生成します。 |
|
ShiftEventTime< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepEvent, DateTime> ) > > )> ) > > )) |
イベントの開始時刻を、有効期間を変更せずに新しいタイムスタンプにシフトします。 |
|
ShiftEventTime< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepEvent, TimeSpan> ) > > )> ) > > )) |
イベントの開始時刻を、有効期間を変更せずに指定の期間シフトします。 |
|
SnapshotWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) |
既定の出力ポリシーでストリームを変換して、各メンバーが CepWindow であるウィンドウ ストリームにします。各ウィンドウは、ストリーム内の最も近いイベント エンドポイントによって定義されるスナップショット ウィンドウです。 |
|
SnapshotWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), SnapshotWindowOutputPolicy) |
ストリームを変換して、各メンバーが CepWindow であるウィンドウ ストリームにします。各ウィンドウは、ストリーム内の最も近いイベント エンドポイントによって定義されるスナップショット ウィンドウです。 |
|
SnapshotWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), WindowInputPolicy, SnapshotWindowOutputPolicy) |
ストリームを変換して、各メンバーが CepWindow であるウィンドウ ストリームにします。各ウィンドウは、ストリーム内の最も近いイベント エンドポイントによって定義されるスナップショット ウィンドウです。 |
|
Take< (Of < <' (TPayload> ) > > )(CepOrderedStream< (Of < <' (TPayload> ) > > ), UInt32) |
順序付けされたストリームが指定されている場合、指定した数のイベントを各ウィンドウから取得します。 |
|
Take< (Of < <' (TInput, TResult> ) > > )(CepOrderedStream< (Of < <' (TInput> ) > > ), UInt32, Expression< (Of < <' (Func< (Of < <' (CepRankedEvent< (Of < <' (TInput> ) > > ), TResult> ) > > )> ) > > )) |
各ウィンドウから指定した数のイベントを取得し、指定した式も評価します。このメソッドは、Take() の結果に順位を射影する場合に使用します。 |
|
ThenBy< (Of < <' (TPayload, TOrderKey> ) > > ) |
rankSelector で示される別の orderKey によって、順序付けされたストリームを並べ替えます。 |
|
ThenByDescending< (Of < <' (TPayload, TOrderKey> ) > > ) |
rankSelector で示される別の orderKey によって、順序付けされたストリームを並べ替えます。 |
|
ToEdgeEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) |
エッジ イベントの CepStream を、IEnumerable インターフェイスを実装するイベント シンクに変換します。イベントの順序は FullyOrdered です。 |
|
ToEdgeEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder) |
エッジ イベントの CepStream を、指定されたイベントの順序で、IEnumerable インターフェイスを実装するイベント シンクに変換します。 |
|
ToEdgeStream< (Of < <' (TInput, TPayload> ) > > ) |
列挙可能な入力ストリームをエッジ イベントのストリームに変換し、入力の時間特性を指定します。 |
|
ToEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) |
イベントのストリームを、イベント ヘッダーの削除と CTI イベントの破棄によって、列挙可能な出力に変換します。 |
|
ToEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder) |
イベントのストリームを、イベント ヘッダーの削除と CTI イベントの破棄によって、指定されたイベントの順序で、列挙可能な出力に変換します。 |
|
ToIntervalEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) |
間隔イベントの CepStream を、IEnumerable インターフェイスを実装するイベント シンクに変換します。イベントの順序は FullyOrdered です。 |
|
ToIntervalEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder) |
間隔イベントの CepStream を、指定されたイベントの順序で、IEnumerable インターフェイスを実装するイベント シンクに変換します。 |
|
ToIntervalStream< (Of < <' (TInput, TPayload> ) > > ) |
列挙可能な入力ストリームを間隔イベントのストリームに変換し、入力の時間特性を指定します。 |
|
ToPointEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) |
ポイント イベントの CepStream を、IEnumerable インターフェイスを実装するイベント シンクに変換します。イベントの順序は FullyOrdered です。 |
|
ToPointEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder) |
ポイント イベントの CepStream を、指定されたイベントの順序で、IEnumerable インターフェイスを実装するイベント シンクに変換します。 |
|
ToPointEventStream< (Of < <' (TPayload> ) > > ) |
イベント開始時刻だけは変更せずに、入力ストリーム内のイベントをポイント イベントに変更します。 |
|
ToPointStream< (Of < <' (TInput, TPayload> ) > > ) |
|
|
ToStream< (Of < <' (TPayload> ) > > )(IEnumerable< (Of < <' (EdgeEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String) |
|
|
ToStream< (Of < <' (TPayload> ) > > )(IEnumerable< (Of < <' (IntervalEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String) |
|
|
ToStream< (Of < <' (TPayload> ) > > )(IEnumerable< (Of < <' (PointEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String) |
|
|
TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan) |
既定の出力ポリシーでストリームを変換して、各メンバーが CepWindow であるウィンドウ ストリームにします。タンブリング ウィンドウとは、ウィンドウ サイズとホップ サイズが同一の特殊なホッピング ウィンドウです。 |
|
TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, HoppingWindowOutputPolicy) |
ストリームを変換して、各メンバーが CepWindow であるウィンドウ ストリームにします。タンブリング ウィンドウとは、ウィンドウ サイズとホップ サイズが同一の特殊なホッピング ウィンドウです。 |
|
TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, DateTime) |
既定の出力ポリシーでストリームを変換して、各メンバーが CepWindow であるウィンドウ ストリームにします。タンブリング ウィンドウとは、ウィンドウ サイズとホップ サイズが同一の特殊なホッピング ウィンドウです。 ウィンドウの開始位置の参照として、配置の時刻を指定することもできます。 |
|
TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy) |
ストリームを変換して、各メンバーが CepWindow であるウィンドウ ストリームにします。タンブリング ウィンドウは、ウィンドウ サイズとホップ サイズが同一の特殊な種類のホッピング ウィンドウです。ウィンドウの開始位置の参照として、配置の時刻を指定することもできます。 |
|
TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, DateTime, HoppingWindowOutputPolicy) |
ストリームを変換して、各メンバーが CepWindow であるウィンドウ ストリームにします。タンブリング ウィンドウは、ウィンドウ サイズとホップ サイズが同一の特殊な種類のホッピング ウィンドウです。ウィンドウの開始位置の参照として、配置の時刻を指定することもできます。 |
|
TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy) |
ストリームを変換して、各メンバーが CepWindow であるウィンドウ ストリームにします。タンブリング ウィンドウは、ウィンドウ サイズとホップ サイズが同一の特殊な種類のホッピング ウィンドウです。ウィンドウの開始位置の参照として、配置の時刻を指定することもできます。 |
|
Union< (Of < <' (TPayload> ) > > ) |
2 つのストリームの和集合を 1 つのストリームにします。 |
|
Where< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, Boolean> ) > > )> ) > > )) |
指定したフィルター関数を使用して、入力ストリームのイベントをフィルター選択します。 |
|
Where< (Of < <' (TInput> ) > > )(ICepEnumerable< (Of < <' (TInput> ) > > ), Expression< (Of < <' (Func< (Of < <' (TInput, Boolean> ) > > )> ) > > )) |
指定したフィルター式を使用して、列挙可能な入力ストリームのイベントをフィルター選択します。 |