CepStream.GroupBy<TPayload, TGroupingKey> Method (CepStream<TPayload>, Expression<Func<TPayload, TGroupingKey>>)

Partitions the input stream by the specified grouping key.

Namespace:   Microsoft.ComplexEventProcessing.Linq
Assembly:  Microsoft.ComplexEventProcessing (in Microsoft.ComplexEventProcessing.dll)

Syntax

public static CepGroupingStreams<TPayload, TGroupingKey> GroupBy<TPayload, TGroupingKey>(
    this CepStream<TPayload> source,
    Expression<Func<TPayload, TGroupingKey>> keySelector
)

public:
generic<typename TPayload, typename TGroupingKey>
[ExtensionAttribute]
static CepGroupingStreams<TPayload, TGroupingKey>^ GroupBy(
    CepStream<TPayload>^ source,
    Expression<Func<TPayload, TGroupingKey>^>^ keySelector
)

static member GroupBy<'TPayload, 'TGroupingKey> : 
        source:CepStream<'TPayload> *
        keySelector:Expression<Func<'TPayload, 'TGroupingKey>> -> CepGroupingStreams<'TPayload, 'TGroupingKey>

<ExtensionAttribute>
Public Shared Function GroupBy(Of TPayload, TGroupingKey) (
    source As CepStream(Of TPayload),
    keySelector As Expression(Of Func(Of TPayload, TGroupingKey))
) As CepGroupingStreams(Of TPayload, TGroupingKey)

Parameters

• source
  Type: Microsoft.ComplexEventProcessing.Linq.CepStream<TPayload>

  The input stream.

• keySelector
  Type: System.Linq.Expressions.Expression<Func<TPayload, TGroupingKey>>

  The expressions for projecting the grouping key.

Return Value

Type: Microsoft.ComplexEventProcessing.Linq.CepGroupingStreams<TPayload, TGroupingKey>

The groups of streams.

Type Parameters

• TPayload
  The payload type of the input events.

• TGroupingKey
  The grouping key event type.

See Also

GroupBy Overload
CepStream Class
Microsoft.ComplexEventProcessing.Linq Namespace

Return to top