ObservableCepStream.ToPointStream<TInput, TPayload> Method (IObservable<TInput>, Application, Expression<Func<TInput, PointEvent<TPayload>>>, AdvanceTimeSettings, String)
Converts an observable input stream to a stream of point events, and provides the temporal characteristics of the input.
Namespace: Microsoft.ComplexEventProcessing.Linq
Assembly: Microsoft.ComplexEventProcessing.Observable (in Microsoft.ComplexEventProcessing.Observable.dll)
Syntax
public static CepStream<TPayload> ToPointStream<TInput, TPayload>(
this IObservable<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(
IObservable<TInput>^ source,
Application^ application,
Expression<Func<TInput, PointEvent<TPayload>^>^>^ selector,
AdvanceTimeSettings^ advanceTimeSettings = null,
String^ streamName = null
)
static member ToPointStream<'TInput, 'TPayload> :
source:IObservable<'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 IObservable(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.IObservable<TInput>The observable input stream.
application
Type: Microsoft.ComplexEventProcessing.ApplicationApplication 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, PointEvent<TPayload>>>An expression that reshapes the input as a stream of point events.
advanceTimeSettings
Type: Microsoft.ComplexEventProcessing.AdvanceTimeSettingsTemporal characteristics of the input.
streamName
Type: System.StringName of the stream.
A stream name supports “importing” CTI events from one stream to another using AdvanceTimeImportSettings. These settings require the user to indicate the name of the input stream from which the CTI events are imported.
Return Value
Type: Microsoft.ComplexEventProcessing.Linq.CepStream<TPayload>
A stream of point events.
Type Parameters
- TInput
Type of the input.
- TPayload
Type of the event payload.
See Also
ObservableCepStream Class
Microsoft.ComplexEventProcessing.Linq Namespace
Return to top