CepStream.CountByStartTimeWindow<TPayload> Method (CepStream<TPayload>, UInt32, WindowInputPolicy, CountWindowOutputPolicy)

Groups input stream events into windows of events based on a given number of unique event start times. The window slides when a new event arrives that starts at a different time.

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

Syntax

public static CepWindowStream<CepWindow<TPayload>> CountByStartTimeWindow<TPayload>(
    this CepStream<TPayload> source,
    uint numberOfEventStartTime,
    WindowInputPolicy inputPolicy,
    CountWindowOutputPolicy outputPolicy
)

public:
generic<typename TPayload>
[ExtensionAttribute]
static CepWindowStream<CepWindow<TPayload>^>^ CountByStartTimeWindow(
    CepStream<TPayload>^ source,
    unsigned int numberOfEventStartTime,
    WindowInputPolicy^ inputPolicy,
    CountWindowOutputPolicy^ outputPolicy
)

static member CountByStartTimeWindow<'TPayload> : 
        source:CepStream<'TPayload> *
        numberOfEventStartTime:uint32 *
        inputPolicy:WindowInputPolicy *
        outputPolicy:CountWindowOutputPolicy -> CepWindowStream<CepWindow<'TPayload>>

<ExtensionAttribute>
Public Shared Function CountByStartTimeWindow(Of TPayload) (
    source As CepStream(Of TPayload),
    numberOfEventStartTime As UInteger,
    inputPolicy As WindowInputPolicy,
    outputPolicy As CountWindowOutputPolicy
) As CepWindowStream(Of CepWindow(Of TPayload))

Parameters

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

  The CepStream to apply the window operation against.

• numberOfEventStartTime
  Type: System.UInt32

  The window size by number of unique event start times.

• inputPolicy
  Type: Microsoft.ComplexEventProcessing.Linq.WindowInputPolicy

  Indicates how events are altered before being input into the window operation.

• outputPolicy
  Type: Microsoft.ComplexEventProcessing.Linq.CountWindowOutputPolicy

  Indicates how output events of the window operation are altered or defined before they are introduced back into the stream.

Return Value

Type: Microsoft.ComplexEventProcessing.Linq.CepWindowStream<CepWindow<TPayload>>

A window stream to which aggregates, ranking or user-defined operations can be applied.

Type Parameters

• TPayload
  The type of the input event payload.

See Also

CountByStartTimeWindow Overload
CepStream Class
Microsoft.ComplexEventProcessing.Linq Namespace

Return to top