Streamable.RegisterAtemporalInput<TPayload> Method
Definition
Important
Some information relates to prerelease product that may be substantially modified before it’s released. Microsoft makes no warranties, express or implied, with respect to the information provided here.
Registers a data source to be used as input with the query container.
public static Microsoft.StreamProcessing.IIngressStreamable<Microsoft.StreamProcessing.Empty,TPayload> RegisterAtemporalInput<TPayload> (this Microsoft.StreamProcessing.QueryContainer container, IObservable<TPayload> data, Microsoft.StreamProcessing.TimelinePolicy timelinePolicy = null, Microsoft.StreamProcessing.OnCompletedPolicy onCompletedPolicy = null, string identifier = null);static member RegisterAtemporalInput : Microsoft.StreamProcessing.QueryContainer * IObservable<'Payload> * Microsoft.StreamProcessing.TimelinePolicy * Microsoft.StreamProcessing.OnCompletedPolicy * string -> Microsoft.StreamProcessing.IIngressStreamable<Microsoft.StreamProcessing.Empty, 'Payload>Type Parameters
- TPayload
The type of the payload of the data source.
Parameters
- container
- QueryContainer
A query containter to which this ingress point can be attached.
- data
- IObservable<TPayload>
A sequence of data elements created by the client.
- timelinePolicy
- TimelinePolicy
Describes how to simulate a progression of time with the data.
- onCompletedPolicy
- OnCompletedPolicy
How to handle the completion of a stream.
- identifier
- String
If provided, a unique name to identify to point of ingress in the query.
Returns
IIngressStreamable<Empty,TPayload>
An IStreamable that can be used in queries.