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

CepStream 類別

提供用於透過 CEP 事件之資料流寫入 LINQ 查詢的擴充方法。

System.Object
  Microsoft.ComplexEventProcessing.Linq.CepStream

命名空間:  Microsoft.ComplexEventProcessing.Linq
組件:  Microsoft.ComplexEventProcessing (在 Microsoft.ComplexEventProcessing.dll 中)

public static class 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>>)使用指定的篩選運算式來篩選可列舉輸入資料流中的事件。
上層

CepStream 是擴充方法的集合。 一般而言,這些擴充方法會傳回 LINQ 方法呼叫運算式。 方法呼叫會以標準格式擷取引動過程順序,然後再轉譯成可執行的 CEP 查詢。

這個型別的任何公用 static (在 Visual Basic 中為 Shared) 成員都是執行緒安全的。並不是所有的執行個體成員都保證可以用於所有的執行緒。
顯示: