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

 

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

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

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

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, IntervalEvent<TPayload>>>

An expression that reshapes the input as a stream of interval 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 interval events.

Type Parameters

TInput

The type of the input.

TPayload

The type of the event payload.

Return to top
Show: