CepGroupingStreams<TPayload, TGroupingKey>.ApplyWithUnion<TUnionOutput, TApplyOutput> 方法 (Expression<Func<CepStream<TPayload>, CepStream<TApplyOutput>>>, Expression<Func<KeyedPayload<TGroupingKey, TApplyOutput>, TUnionOutput>>)

  • 發行項

 

將 applybranch 參數指定的查詢邏輯套用到群組的資料流。 每個群組會產生一個結果資料流，並將所有結果資料流聯集在一起。 selector 參數是一個 Lambda 運算式，可允許輸出的其他投射作業，並提供群組欄位的存取權。

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

語法

public CepStream<TUnionOutput> ApplyWithUnion<TUnionOutput, TApplyOutput>(
    Expression<Func<CepStream<TPayload>, CepStream<TApplyOutput>>> applybranch,
    Expression<Func<KeyedPayload<TGroupingKey, TApplyOutput>, TUnionOutput>> selector
)

public:
generic<typename TUnionOutput, typename TApplyOutput>
CepStream<TUnionOutput>^ ApplyWithUnion(
    Expression<Func<CepStream<TPayload>^, CepStream<TApplyOutput>^>^>^ applybranch,
    Expression<Func<KeyedPayload<TGroupingKey, TApplyOutput>, TUnionOutput>^>^ selector
)

member ApplyWithUnion<'TUnionOutput, 'TApplyOutput> : 
        applybranch:Expression<Func<CepStream<'TPayload>, CepStream<'TApplyOutput>>> *
        selector:Expression<Func<KeyedPayload<'TGroupingKey, 'TApplyOutput>, 'TUnionOutput>> -> CepStream<'TUnionOutput>

Public Function ApplyWithUnion(Of TUnionOutput, TApplyOutput) (
    applybranch As Expression(Of Func(Of CepStream(Of TPayload), CepStream(Of TApplyOutput))),
    selector As Expression(Of Func(Of KeyedPayload(Of TGroupingKey, TApplyOutput), TUnionOutput))
) As CepStream(Of TUnionOutput)

參數

  • applybranch
    要套用到每個群組的查詢。
  • selector
    用於輸出投射的 Lambda 運算式。

傳回值

Type: Microsoft.ComplexEventProcessing.Linq.CepStream<TUnionOutput>

具有 TApplyOutput 的資料流，做為事件裝載類型。

類型參數

  • TUnionOutput
    位於群組等位輸出的事件類型。
  • TApplyOutput
    位於套用輸出的事件裝載類型。

備註

群組資料流就是針對資料流進行群組依據作業的結果。

請參閱

ApplyWithUnion 超載
CepGroupingStreams<TPayload, TGroupingKey> 類別
Microsoft.ComplexEventProcessing.Linq 命名空間

回到頁首