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