CepGroupingStreams<TPayload, TGroupingKey>.ApplyWithUnion<TApplyOutput> Method (Expression<Func<CepStream<TPayload>, CepStream<TApplyOutput>>>)
Applies the query logic specified by the applybranch parameter to a grouped stream. Produces a result stream per group and unions all result streams together.
Namespace: Microsoft.ComplexEventProcessing.Linq
Assembly: Microsoft.ComplexEventProcessing (in Microsoft.ComplexEventProcessing.dll)
Syntax
public CepStream<TApplyOutput> ApplyWithUnion<TApplyOutput>(
Expression<Func<CepStream<TPayload>, CepStream<TApplyOutput>>> applybranch
)
Type Parameters
- 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.
Return Value
Type: Microsoft.ComplexEventProcessing.Linq.CepStream<TApplyOutput>
Stream with TApplyOutput as the event payload type.
Remarks
The grouped stream is a result of a group-by operation on a stream.