CepGroupingStreams<TPayload, TGroupingKey>.ApplyWithUnion<TUnionOutput, TApplyOutput> Method (Expression<Func<CepStream<TPayload>, CepStream<TApplyOutput>>>, Expression<Func<KeyedPayload<TGroupingKey, TApplyOutput>, TUnionOutput>>)
Supplies the query logic specified by the applybranch parameter to a grouped stream. Produces a result stream per group and unions all result streams together. The selector parameter is a lambda expression that allows additional project operations on the output and provides access to grouping fields.
Namespace: Microsoft.ComplexEventProcessing.Linq
Assembly: Microsoft.ComplexEventProcessing (in Microsoft.ComplexEventProcessing.dll)
Syntax
public CepStream<TUnionOutput> ApplyWithUnion<TUnionOutput, TApplyOutput>(
Expression<Func<CepStream<TPayload>, CepStream<TApplyOutput>>> applybranch,
Expression<Func<KeyedPayload<TGroupingKey, TApplyOutput>, TUnionOutput>> selector
)
Type Parameters
- TUnionOutput
Event type at the output of the group union
- TApplyOutput
Event payload type at the output of the apply.
Parameters
- applybranch
Type: System.Linq.Expressions.Expression<Func<CepStream<TPayload>, CepStream<TApplyOutput>>>
Query to be applied to each group.
- selector
Type: System.Linq.Expressions.Expression<Func<KeyedPayload<TGroupingKey, TApplyOutput>, TUnionOutput>>
Lambda expression for projections of the output.
Return Value
Type: Microsoft.ComplexEventProcessing.Linq.CepStream<TUnionOutput>
A stream with TApplyOutput as event payload type.
Remarks
The grouped stream is a result of a group-by operation on a stream.