Método ApplyWithUnion(TUnionOutput, TApplyOutput) (Expression(Func(CepStream(TPayload), CepStream(TApplyOutput))), Expression(Func(KeyedPayload(TGroupingKey, TApplyOutput), TUnionOutput)))
Fornece a lógica de consulta especificada pelo parâmetro applybranch a um fluxo agrupado. Gera um fluxo de resultado por grupo e une todos os fluxos de resultado juntos. O parâmetro selector é uma expressão lambda que permite operações de projeto adicionais na saída e fornece acesso a campos de agrupamento.
Namespace: Microsoft.ComplexEventProcessing.Linq
Assembly: Microsoft.ComplexEventProcessing (em Microsoft.ComplexEventProcessing.dll)
Sintaxe
public CepStream<TUnionOutput> ApplyWithUnion<TUnionOutput, TApplyOutput>(
Expression<Func<CepStream<TPayload>, CepStream<TApplyOutput>>> applybranch,
Expression<Func<KeyedPayload<TGroupingKey, TApplyOutput>, TUnionOutput>> selector
)
Parâmetros de tipo
- TUnionOutput
Tipo de carga de evento na saída da união de grupo.
- TApplyOutput
Tipo de carga de evento na saída da aplicação.
Parâmetros
- applybranch
Tipo: System.Linq.Expressions. . :: . .Expression< (Of < ( <'Func< (Of < ( <'CepStream< (Of < ( <'TPayload> ) > ) >, CepStream< (Of < ( <'TApplyOutput> ) > ) >> ) > ) >> ) > ) >
Consulta a ser aplicada a cada grupo.
- selector
Tipo: System.Linq.Expressions. . :: . .Expression< (Of < ( <'Func< (Of < ( <'KeyedPayload< (Of < ( <'TGroupingKey, TApplyOutput> ) > ) >, TUnionOutput> ) > ) >> ) > ) >
Expressão lambda para projeções da saída.
Valor de retorno
Tipo: Microsoft.ComplexEventProcessing.Linq. . :: . .CepStream< (Of < ( <'TUnionOutput> ) > ) >
Um fluxo com TApplyOutput como o tipo de carga de evento.
Comentários
O fluxo agrupado é o resultado de uma operação agrupar por em um fluxo.
Consulte também
Referência
CepGroupingStreams< (Of < ( <'TPayload, TGroupingKey> ) > ) > Classe