CepStream 類別

  • 發行項

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

繼承階層

System. . :: . .Object
  Microsoft.ComplexEventProcessing.Linq..::..CepStream

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

語法

public static class CepStream

CepStream 型別公開下列成員。

方法

  名稱 說明
公用方法靜態成員 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> ) > > )> ) > > )) 使用指定的篩選運算式來篩選可列舉輸入資料流中的事件。

上層

備註

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

執行緒安全性

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

請參閱

參考

Microsoft.ComplexEventProcessing.Linq 命名空間