Share via


CepOrderedStream(T) 類別

已排序的資料流是「排序依據」的結果,或查詢中其中一個變數的結果。它會協助將後續的查詢規格限制為已排序之資料流所允許的作業,例如 Take。

繼承階層

System. . :: . .Object
  Microsoft.ComplexEventProcessing.Linq..::..CepOrderedStream<(Of <(<'T>)>)>

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

語法

public class CepOrderedStream<T>

型別參數

  • T

CepOrderedStream<(Of <(<'T>)>)> 型別公開下列成員。

方法

  名稱 說明
公用方法 Equals (繼承自 Object。)
受保護的方法 Finalize (繼承自 Object。)
公用方法 GetHashCode (繼承自 Object。)
公用方法 GetType (繼承自 Object。)
受保護的方法 MemberwiseClone (繼承自 Object。)
公用方法 ToString (繼承自 Object。)

上層

擴充 方法

  名稱 說明
公用擴充方法 Select< (Of < <' (TInput, TResult> ) > > ) 假設有已排序的資料流,此方法會產生可用於排名的已排序資料流。 (由 CepStream 定義。)
公用擴充方法 Take< (Of < <' (TPayload> ) > > )(UInt32) 已多載。 假設有已排序的資料流,請從每個視窗取出給定的事件數目。 (由 CepStream 定義。)
公用擴充方法 Take< (Of < <' (TInput, TResult> ) > > )(UInt32, Expression< (Of < <' (Func< (Of < <' (CepRankedEvent< (Of < <' (TInput> ) > > ), TResult> ) > > )> ) > > )) 已多載。 從每個視窗取出給定的事件數目,並同時評估給定的運算式。這適用於您想要將次序投射到 Take() 結果中的情況。 (由 CepStream 定義。)
公用擴充方法 ThenBy< (Of < <' (TPayload, TOrderKey> ) > > ) 依其他 orderKey 排序已排序的資料流,如 rankSelector 所指示。 (由 CepStream 定義。)
公用擴充方法 ThenByDescending< (Of < <' (TPayload, TOrderKey> ) > > ) 依其他 orderKey 排序已排序的資料流,如 rankSelector 所指示。 (由 CepStream 定義。)

上層

備註

一旦資料流經過排序之後,它就必須接著進行 Take 作業,以便產生可進一步撰寫的一般 CEP 資料流。

執行緒安全性

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

請參閱

參考

Microsoft.ComplexEventProcessing.Linq 命名空間