若要檢視英文版的文章,請選取 [原文] 核取方塊。您也可以將滑鼠指標移到文字上,即可在快顯視窗顯示英文原文。
譯文
原文

CepStream 方法

CepStream 型別公開下列成員。

  名稱 說明
公用方法 靜態成員 AlterEventDuration<TPayload> 變更輸入事件的持續時間。 這個方法並不會變更事件的開始時間。
公用方法 靜態成員 AlterEventLifetime<TPayload> 改變資料流中的事件存留期間。 這個方法可以同時變更事件的開始時間和結束時間。
公用方法 靜態成員 ClipEventDuration<TSource, TClip> sourceStream 中的事件存留期間縮短為與 matchExpression 相符之 clipStream 中下一個對應事件的開始時間。
公用方法 靜態成員 CountByStartTimeWindow<TPayload>(CepStream<TPayload>, UInt32) 使用預設輸出原則,根據給定的唯一事件啟動次數,將輸入資料流事件分組到事件的視窗。 當在不同時間啟動的新事件抵達時,此視窗會滑動。
公用方法 靜態成員 CountByStartTimeWindow<TPayload>(CepStream<TPayload>, UInt32, CountWindowOutputPolicy) 根據給定的唯一事件啟動次數,將輸入資料流事件分組到事件的視窗。 當在不同時間啟動的新事件抵達時,此視窗會滑動。
公用方法 靜態成員 CountByStartTimeWindow<TPayload>(CepStream<TPayload>, UInt32, WindowInputPolicy, CountWindowOutputPolicy) 根據給定的唯一事件啟動次數,將輸入資料流事件分組到事件的視窗。 當在不同時間啟動的新事件抵達時,此視窗會滑動。
公用方法 靜態成員 GroupBy<TPayload, TGroupingKey>(CepStream<TPayload>, Expression<Func<TPayload, TGroupingKey>>) 依指定的群組索引鍵分割輸入資料流。
公用方法 靜態成員 GroupBy<TPayload, TGroupingKey, TResult>(CepStream<TPayload>, Expression<Func<TPayload, TGroupingKey>>, Expression<Func<TPayload, TResult>>) 依指定的索引鍵選取器函數來分組來源資料流,然後使用元素選擇器函數投射結果。
公用方法 靜態成員 HoppingWindow<TPayload>(CepStream<TPayload>, TimeSpan, TimeSpan) 將資料流轉換為視窗資料流,其中每個成員都是使用預設輸出原則的 CepWindow。
公用方法 靜態成員 HoppingWindow<TPayload>(CepStream<TPayload>, TimeSpan, TimeSpan, HoppingWindowOutputPolicy) 將資料流轉換為視窗資料流,其中每個成員都是使用預設輸出原則的 CepWindow。
公用方法 靜態成員 HoppingWindow<TPayload>(CepStream<TPayload>, TimeSpan, TimeSpan, DateTime) 將資料流轉換為視窗資料流,其中每個成員都是使用預設輸出原則的 CepWindow。
公用方法 靜態成員 HoppingWindow<TPayload>(CepStream<TPayload>, TimeSpan, TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy) 將資料流轉換為視窗資料流,其中每個成員都是使用預設輸出原則的 CepWindow。
公用方法 靜態成員 HoppingWindow<TPayload>(CepStream<TPayload>, TimeSpan, TimeSpan, DateTime, HoppingWindowOutputPolicy) 將資料流轉換為視窗資料流,其中每個成員都是一個 CepWindow。
公用方法 靜態成員 HoppingWindow<TPayload>(CepStream<TPayload>, TimeSpan, TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy) 此視窗是由常數視窗大小和躍點大小時間範圍所定義。
公用方法 靜態成員 IsEmpty<TPayload> 在指定的資料流上執行左方反半聯結 (LASJ) 查詢。
公用方法 靜態成員 Join<TOuter, TInner, TKey, TResult> 在給定的聯結索引鍵上,將外部資料流的事件與內部資料流的事件聯結在一起。
公用方法 靜態成員 OrderBy<TPayload, TOrderKey> rankSelector 排序輸入資料流。
公用方法 靜態成員 OrderByDescending<TPayload, TOrderKey> rankSelector 以遞減順序排序輸入資料流。
公用方法 靜態成員 Scan<TInputEvent, TInputPayload, TOutputPayload> 使用使用者定義的資料流運算子掃描輸入資料流。
公用方法 靜態成員 Select<TInput, TResult>(CepOrderedStream<TInput>, Expression<Func<TInput, TResult>>) 假設有已排序的資料流,此方法會產生可用於排名的已排序資料流。
公用方法 靜態成員 Select<TPayload, TResult>(CepStream<TPayload>, Expression<Func<TPayload, TResult>>) 使用投射運算式投射來自輸入資料流的事件。
公用方法 靜態成員 Select<TInput, TResult>(CepWindowStream<CepWindow<TInput>>, Expression<Func<CepWindow<TInput>, TResult>>) 根據給定的對應運算式,將視窗資料流對應到某個資料流。
公用方法 靜態成員 Select<TInput, TOutput>(ICepEnumerable<TInput>, Expression<Func<TInput, TOutput>>) 將可列舉輸入資料流的每一個事件投射到新的事件。
公用方法 靜態成員 SelectMany<TInput, TResult>(CepWindowStream<CepWindow<TInput>>, Expression<Func<CepWindow<TInput>, CepWindow<TInput>>>, Expression<Func<CepWindow<TInput>, TInput, TResult>>) 支援針對視窗型資料流,依運算排序。
公用方法 靜態成員 SelectMany<TInput, TBind, TResult>(CepStream<TInput>, Expression<Func<CepStream<TInput>, CepStream<TBind>>>, Expression<Func<TInput, TBind, TResult>>) 根據兩個輸入資料流的交叉聯結,產生資料流。
公用方法 靜態成員 SelectMany<TInput, TGroupingKey, TBind, TResult>(CepGroupingStreams<TInput, TGroupingKey>, Expression<Func<CepStream<TInput>, CepStream<TBind>>>, Expression<Func<IKey<TGroupingKey>, TBind, TResult>>) 支援在群組及套用內部加入查詢邏輯。
公用方法 靜態成員 SelectMany<TInput, TGroupingKey, TBind, TResult>(CepGroupingStreams<TInput, TGroupingKey>, Expression<Func<CepStream<TInput>, CepWindowStream<TBind>>>, Expression<Func<IKey<TGroupingKey>, TBind, TResult>>) 在群組資料流的上方啟用視窗作業。
公用方法 靜態成員 ShiftEventTime<TPayload>(CepStream<TPayload>, Expression<Func<CepEvent, DateTime>>) shiftExpr 參數指定的值移位事件時間。 這個方法並不會變更事件的存留期間。
公用方法 靜態成員 ShiftEventTime<TPayload>(CepStream<TPayload>, Expression<Func<CepEvent, TimeSpan>>) shiftExpr 參數指定的數量移位事件時間。 傳回的值可能是正數或負數。
公用方法 靜態成員 SnapshotWindow<TPayload>(CepStream<TPayload>) 將資料流轉換為視窗資料流,其中每個成員都是使用預設輸出原則的 CepWindow
公用方法 靜態成員 SnapshotWindow<TPayload>(CepStream<TPayload>, SnapshotWindowOutputPolicy) 將資料流轉換為視窗資料流,其中每個成員都是一個 CepWindow
公用方法 靜態成員 SnapshotWindow<TPayload>(CepStream<TPayload>, WindowInputPolicy, SnapshotWindowOutputPolicy) 將資料流轉換為視窗資料流,其中每個成員都是一個 CepWindow
公用方法 靜態成員 Take<TPayload>(CepOrderedStream<TPayload>, UInt32) 假設有已排序的資料流,請從每個視窗取出給定的事件數目。
公用方法 靜態成員 Take<TInput, TResult>(CepOrderedStream<TInput>, UInt32, Expression<Func<CepRankedEvent<TInput>, TResult>>) 從每個視窗取出給定的事件數目,並同時評估給定的運算式。 這適用於您想要將次序投射到 Take() 結果中的情況。
公用方法 靜態成員 ThenBy<TPayload, TOrderKey> 依另一個排序索引鍵排序已排序的資料流,如 rankSelector 所指示。
公用方法 靜態成員 ThenByDescending<TPayload, TOrderKey> 依另一個排序索引鍵排序已排序的資料流,如 rankSelector 所指示。
公用方法 靜態成員 ToEdgeEnumerable<TPayload>(CepStream<TPayload>) 將邊緣事件的 CepStream 轉換成實作 IEnumerable 介面的事件接收。
公用方法 靜態成員 ToEdgeEnumerable<TPayload>(CepStream<TPayload>, StreamEventOrder) 將邊緣事件的 CepStream 轉換成實作 IEnumerable 介面的事件接收。
公用方法 靜態成員 ToEdgeStream<TInput, TPayload> 將可列舉輸入資料流轉換為邊緣事件資料流,並提供暫時的輸入特性。
公用方法 靜態成員 ToEnumerable<TPayload>(CepStream<TPayload>) 藉由移除事件標頭及捨棄 CTI 事件的方式將事件資料流轉換為可列舉輸出。
公用方法 靜態成員 ToEnumerable<TPayload>(CepStream<TPayload>, StreamEventOrder) 藉由移除事件標頭及捨棄 CTI 事件的方式,以指定的事件順序將事件資料流轉換為可列舉輸出。
公用方法 靜態成員 ToIntervalEnumerable<TPayload>(CepStream<TPayload>) 將間隔事件的 CepStream 轉換成實作 IEnumerable 介面的事件接收。 事件的順序為 FullyOrdered
公用方法 靜態成員 ToIntervalEnumerable<TPayload>(CepStream<TPayload>, StreamEventOrder) 以指定的事件順序將間隔事件的 CepStream 轉換成實作 IEnumerable 介面的事件接收。
公用方法 靜態成員 ToIntervalStream<TInput, TPayload> 將可列舉輸入資料流轉換為間隔事件資料流,並提供暫時的輸入特性。
公用方法 靜態成員 ToPointEnumerable<TPayload>(CepStream<TPayload>) 將時間點事件的 CepStream 轉換成實作 IEnumerable 介面的事件接收。 事件的順序為 FullyOrdered
公用方法 靜態成員 ToPointEnumerable<TPayload>(CepStream<TPayload>, StreamEventOrder) 以指定的事件順序將時間點事件的 CepStream 轉換成實作 IEnumerable 介面的事件接收。
公用方法 靜態成員 ToPointEventStream<TPayload> 透過只保留事件開始時間,將輸入資料流中的事件變更為時間點事件。
公用方法 靜態成員 ToPointStream<TInput, TPayload> 將時間點事件的 CepStream 轉換成事件接收。
公用方法 靜態成員 ToStream<TPayload>(IEnumerable<EdgeEvent<TPayload>>, Application, AdvanceTimeSettings, String) 將時間點事件的 CepStream 轉換成資料流。
公用方法 靜態成員 ToStream<TPayload>(IEnumerable<IntervalEvent<TPayload>>, Application, AdvanceTimeSettings, String) 將時間點事件的 CepStream 轉換成資料流。
公用方法 靜態成員 ToStream<TPayload>(IEnumerable<PointEvent<TPayload>>, Application, AdvanceTimeSettings, String) 將時間點事件的 CepStream 轉換成資料流。
公用方法 靜態成員 TumblingWindow<TPayload>(CepStream<TPayload>, TimeSpan) 將資料流轉換為視窗資料流,其中每個成員都是使用預設輸出原則的 CepWindow
公用方法 靜態成員 TumblingWindow<TPayload>(CepStream<TPayload>, TimeSpan, HoppingWindowOutputPolicy) 將資料流轉換為視窗資料流,其中每個成員都是一個 CepWindow
公用方法 靜態成員 TumblingWindow<TPayload>(CepStream<TPayload>, TimeSpan, DateTime) 將資料流轉換為視窗資料流,其中每個成員都是使用預設輸出原則的 CepWindow
公用方法 靜態成員 TumblingWindow<TPayload>(CepStream<TPayload>, TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy) 將資料流轉換為視窗資料流,其中每個成員都是一個 CepWindow
公用方法 靜態成員 TumblingWindow<TPayload>(CepStream<TPayload>, TimeSpan, DateTime, HoppingWindowOutputPolicy) 將資料流轉換為視窗資料流,其中每個成員都是一個 CepWindow
公用方法 靜態成員 TumblingWindow<TPayload>(CepStream<TPayload>, TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy) 將資料流轉換為視窗資料流,其中每個成員都是一個 CepWindow
公用方法 靜態成員 Union<TPayload> 將兩個資料流聯集在一起放在一個資料流中。
公用方法 靜態成員 Where<TPayload>(CepStream<TPayload>, Expression<Func<TPayload, Boolean>>) 使用給定的篩選函數來篩選輸入資料流中的事件。
公用方法 靜態成員 Where<TInput>(ICepEnumerable<TInput>, Expression<Func<TInput, Boolean>>) 使用指定的篩選運算式來篩選可列舉輸入資料流中的事件。
上層
顯示: