|
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> ) > > ) |
查詢中用來表示左方反半聯結 (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> ) > > )> ) > > )) |
根據給定的對應運算式,將視窗資料流對應到某個資料流。 |
|
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> ) > > )> ) > > )) |
支援針對視窗型資料流,依運算排序。 |
|
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> ) > > )> ) > > )) |
根據兩個輸入資料流的交叉聯結,產生資料流。 |
|
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> ) > > )> ) > > )) |
根據兩個輸入資料流的交叉聯結,產生資料流。 |
|
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> ) > > ) |
依其他 orderKey 排序已排序的資料流,如 rankSelector 所指示。 |
|
ThenByDescending< (Of < <' (TPayload, TOrderKey> ) > > ) |
依其他 orderKey 排序已排序的資料流,如 rankSelector 所指示。 |
|
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> ) > > ) |
將兩個資料流聯集在一起放在一個資料流中。 |
|
Where< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, Boolean> ) > > )> ) > > )) |
使用給定的篩選函數來篩選輸入資料流中的事件。 |
|
Where< (Of < <' (TInput> ) > > )(ICepEnumerable< (Of < <' (TInput> ) > > ), Expression< (Of < <' (Func< (Of < <' (TInput, Boolean> ) > > )> ) > > )) |
使用指定的篩選運算式來篩選可列舉輸入資料流中的事件。 |