CepGroupingStreams<TPayload, TGroupingKey> Class
Represents a group of streams.
Namespace: Microsoft.ComplexEventProcessing.Linq
Assembly: Microsoft.ComplexEventProcessing (in Microsoft.ComplexEventProcessing.dll)
Inheritance Hierarchy
System.Object
Microsoft.ComplexEventProcessing.Linq.CepGroupingStreams<TPayload, TGroupingKey>
Syntax
public class CepGroupingStreams<TPayload, TGroupingKey>
generic<typename TPayload, typename TGroupingKey>
public ref class CepGroupingStreams
type CepGroupingStreams<'TPayload, 'TGroupingKey> = class end
Public Class CepGroupingStreams(Of TPayload, TGroupingKey)
Type Parameters
- TPayload
Payload type.
- TGroupingKey
Payload type.
Methods
Name | Description | |
---|---|---|
ApplyWithUnion<TApplyOutput>(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. |
|
ApplyWithUnion<TUnionOutput, TApplyOutput>(Expression<Func<CepStream<TPayload>, CepStream<TApplyOutput>>>, Expression<Func<KeyedPayload<TGroupingKey, TApplyOutput>, TUnionOutput>>) | 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. The selector parameter is a lambda expression that allows additional project operations on the output and provides access to grouping fields. |
|
Equals(Object) | (Inherited from Object.) |
|
Finalize() | (Inherited from Object.) |
|
GetHashCode() | (Inherited from Object.) |
|
GetType() | (Inherited from Object.) |
|
MemberwiseClone() | (Inherited from Object.) |
|
ToString() | (Inherited from Object.) |
Remarks
CepGroupingStreams restricts the programming surface area once a grouping construct has been specified. The set of methods exposed to the programmer cover multiple types. Each of these types surfaces only the set of operators available to the programmer. The transition between any of these types is carefully controlled by the operations so that problems surface early at compile time rather than at runtime.
Thread Safety
Any public static (Shared in Visual Basic) members of this type are thread safe. Any instance members are not guaranteed to be thread safe.
See Also
Microsoft.ComplexEventProcessing.Linq Namespace
Return to top