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)
Syntax
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
)
public:
generic<typename TInput, typename TPayload>
[ExtensionAttribute]
static CepStream<TPayload>^ ToIntervalStream(
IEnumerable<TInput>^ source,
Application^ application,
Expression<Func<TInput, IntervalEvent<TPayload>^>^>^ selector,
AdvanceTimeSettings^ advanceTimeSettings = null,
String^ streamName = null
)
static member ToIntervalStream<'TInput, 'TPayload> :
source:IEnumerable<'TInput> *
application:Application *
selector:Expression<Func<'TInput, IntervalEvent<'TPayload>>> *
advanceTimeSettings:AdvanceTimeSettings = null *
streamName:string = null -> CepStream<'TPayload>
<ExtensionAttribute>
Public Shared Function ToIntervalStream(Of TInput, TPayload) (
source As IEnumerable(Of TInput),
application As Application,
selector As Expression(Of Func(Of TInput, IntervalEvent(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.ApplicationAn 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.AdvanceTimeSettingsThe temporal characteristics of the input.
streamName
Type: System.StringA 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.
See Also
CepStream Class
Microsoft.ComplexEventProcessing.Linq Namespace
Return to top