Share via


ObservableCepStream.ToPointStream<TInput, TPayload> Method

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,
    string streamName
)

Type Parameters

  • TInput
    Type of the input.
  • TPayload
    Type of the event payload.

Parameters

  • application
    Type: Microsoft.ComplexEventProcessing.Application
    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.
  • streamName
    Type: System.String
    Name 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.

Usage Note

In Visual Basic and C#, you can call this method as an instance method on any object of type IObservable<TInput>. When you use instance method syntax to call this method, omit the first parameter. For more information, see https://msdn.microsoft.com/en-us/library/bb384936(v=sql.105) or https://msdn.microsoft.com/en-us/library/bb383977(v=sql.105).

See Also

Reference

ObservableCepStream Class

Microsoft.ComplexEventProcessing.Linq Namespace