CepStream.Take<TPayload> Method (CepOrderedStream<TPayload>, UInt32)

  • Article

 

Given an ordered stream, takes a given number of events from each window.

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

Syntax

public static CepStream<TPayload> Take<TPayload>(
    this CepOrderedStream<TPayload> source,
    uint numberOfElements
)

public:
generic<typename TPayload>
[ExtensionAttribute]
static CepStream<TPayload>^ Take(
    CepOrderedStream<TPayload>^ source,
    unsigned int numberOfElements
)

static member Take<'TPayload> : 
        source:CepOrderedStream<'TPayload> *
        numberOfElements:uint32 -> CepStream<'TPayload>

<ExtensionAttribute>
Public Shared Function Take(Of TPayload) (
    source As CepOrderedStream(Of TPayload),
    numberOfElements As UInteger
) As CepStream(Of TPayload)

Parameters

  • numberOfElements
    Type: System.UInt32

    The number of elements to take from each window.

Return Value

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

A stream with a given number of events taken from each window.

Type Parameters

  • TPayload
    The payload type of input events.

See Also

Take Overload
CepStream Class
Microsoft.ComplexEventProcessing.Linq Namespace

Return to top