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

Converts an enumerable input stream to a stream of edge events, and provides the temporal characteristics of the input.

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

Syntax

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

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

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

<ExtensionAttribute>
Public Shared Function ToEdgeStream(Of TInput, TPayload) (
    source As IEnumerable(Of TInput),
    application As Application,
    selector As Expression(Of Func(Of TInput, EdgeEvent(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. This parameter cannot be null. The application must belong to an embedded server that was generated by calling one of the overloads of Server.Create.

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

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

• advanceTimeSettings
  Type: Microsoft.ComplexEventProcessing.AdvanceTimeSettings

  The 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 edge 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