CepStream.ToPointStream<TInput, TPayload> Method (IEnumerable<TInput>, Application, Expression<Func<TInput, PointEvent<TPayload>>>, AdvanceTimeSettings, String)

Converts a CepStream of point events to an event sink.

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

Syntax

public static CepStream<TPayload> ToPointStream<TInput, TPayload>(
    this IEnumerable<TInput> source,
    Application application,
    Expression<Func<TInput, PointEvent<TPayload>>> selector,
    AdvanceTimeSettings advanceTimeSettings = null,
    string streamName = null
)

public:
generic<typename TInput, typename TPayload>
[ExtensionAttribute]
static CepStream<TPayload>^ ToPointStream(
    IEnumerable<TInput>^ source,
    Application^ application,
    Expression<Func<TInput, PointEvent<TPayload>^>^>^ selector,
    AdvanceTimeSettings^ advanceTimeSettings = null,
    String^ streamName = null
)

static member ToPointStream<'TInput, 'TPayload> : 
        source:IEnumerable<'TInput> *
        application:Application *
        selector:Expression<Func<'TInput, PointEvent<'TPayload>>> *
        advanceTimeSettings:AdvanceTimeSettings = null *
        streamName:string = null -> CepStream<'TPayload>

<ExtensionAttribute>
Public Shared Function ToPointStream(Of TInput, TPayload) (
    source As IEnumerable(Of TInput),
    application As Application,
    selector As Expression(Of Func(Of TInput, PointEvent(Of TPayload))),
    advanceTimeSettings As AdvanceTimeSettings,
    streamName As String
) As CepStream(Of TPayload)

Parameters

• source
  Type: System.Collections.Generic.IEnumerable<TInput>

  The enumerable input stream.

• application
  Type: Microsoft.ComplexEventProcessing.Application

  An application instance that hosts the event source.

• selector
  Type: System.Linq.Expressions.Expression<Func<TInput, PointEvent<TPayload>>>

  An expression that reshapes the input as a stream of point events.

• advanceTimeSettings
  Type: Microsoft.ComplexEventProcessing.AdvanceTimeSettings

  Temporal characteristics of the input.

• streamName
  Type: System.String

  A stream name supports “importing” CTI events from one stream to another using AdvanceTimeImportSettings.

Return Value

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

A stream of point events.

Type Parameters

• TInput
  The type of the input.

• TPayload
  The type of the event payload.

See Also

CepStream Class
Microsoft.ComplexEventProcessing.Linq Namespace

Return to top