Share via


CepGroupingStreams<TPayload, TGroupingKey> Class

Represents a group of streams.

Inheritance Hierarchy

System.Object
  Microsoft.ComplexEventProcessing.Linq.CepGroupingStreams<TPayload, TGroupingKey>

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

Syntax

public class CepGroupingStreams<TPayload, TGroupingKey>

Type Parameters

  • TPayload
    The type of the event payload.
  • TGroupingKey
    The type of the grouping key.

The CepGroupingStreams<TPayload, TGroupingKey> type exposes the following members.

Methods

  Name Description
Public method 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.
Public method ApplyWithUnion<TUnionOutput, TApplyOutput>(Expression<Func<CepStream<TPayload>, CepStream<TApplyOutput>>>, Expression<Func<KeyedPayload<TGroupingKey, TApplyOutput>, TUnionOutput>>) Supplies 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.
Public method Equals (Inherited from Object.)
Protected method Finalize (Inherited from Object.)
Public method GetHashCode (Inherited from Object.)
Public method GetType (Inherited from Object.)
Protected method MemberwiseClone (Inherited from Object.)
Public method ToString (Inherited from Object.)

Top

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

Reference

Microsoft.ComplexEventProcessing.Linq Namespace