Streamable.RegisterTemporalInput 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.
Overloads
| RegisterTemporalInput<TPayload>(QueryContainer, IObservable<TPayload>, Expression<Func<TPayload,Int64>>, OnCompletedPolicy, PeriodicPunctuationPolicy, String) |
Converts a sequence of data elements to an IStreamable, start-edge only.
The completion policy specifies what to do when the resulting stream completes.
The disorder policy specifies what to do with out of order events.
The punctuation policy specifies whether and how punctuations are created and injected |
| RegisterTemporalInput<TPayload>(QueryContainer, IObservable<TPayload>, Expression<Func<TPayload,Int64>>, OnCompletedPolicy, DisorderPolicy, PeriodicPunctuationPolicy, String) |
Converts a sequence of data elements to an IStreamable, start-edge only.
The completion policy specifies what to do when the resulting stream completes.
The disorder policy specifies what to do with out of order events.
The punctuation policy specifies whether and how punctuations are created and injected |
| RegisterTemporalInput<TPayload>(QueryContainer, IObservable<TPayload>, Expression<Func<TPayload,Int64>>, Expression<Func<TPayload,Int64>>, OnCompletedPolicy, PeriodicPunctuationPolicy, String) |
Converts a sequence of data elements to an IStreamable, intervals and start-edges only.
The completion policy specifies what to do when the resulting stream completes.
The disorder policy specifies what to do with out of order events.
The punctuation policy specifies whether and how punctuations are created and injected |
| RegisterTemporalInput<TPayload>(QueryContainer, IObservable<TPayload>, Expression<Func<TPayload,Int64>>, Expression<Func<TPayload,Int64>>, OnCompletedPolicy, DisorderPolicy, PeriodicPunctuationPolicy, String) |
Converts a sequence of data elements to an IStreamable, intervals and start-edges only.
The completion policy specifies what to do when the resulting stream completes.
The disorder policy specifies what to do with out of order events.
The punctuation policy specifies whether and how punctuations are created and injected |
RegisterTemporalInput<TPayload>(QueryContainer, IObservable<TPayload>, Expression<Func<TPayload,Int64>>, OnCompletedPolicy, PeriodicPunctuationPolicy, String)
Converts a sequence of data elements to an IStreamable, start-edge only.
The completion policy specifies what to do when the resulting stream completes.
The disorder policy specifies what to do with out of order events.
The punctuation policy specifies whether and how punctuations are created and injected
into the resulting stream. Since punctuations force output, this exposes a throughput/latency tradeoff.
public static Microsoft.StreamProcessing.IObservableIngressStreamable<TPayload> RegisterTemporalInput<TPayload> (this Microsoft.StreamProcessing.QueryContainer container, IObservable<TPayload> streamEvents, System.Linq.Expressions.Expression<Func<TPayload,long>> startEdgeExtractor, Microsoft.StreamProcessing.OnCompletedPolicy onCompletedPolicy, Microsoft.StreamProcessing.PeriodicPunctuationPolicy periodicPunctuationPolicy, string identifier = null);static member RegisterTemporalInput : Microsoft.StreamProcessing.QueryContainer * IObservable<'Payload> * System.Linq.Expressions.Expression<Func<'Payload, int64>> * Microsoft.StreamProcessing.OnCompletedPolicy * Microsoft.StreamProcessing.PeriodicPunctuationPolicy * string -> Microsoft.StreamProcessing.IObservableIngressStreamable<'Payload>Type Parameters
- TPayload
The type of data for the stream.
Parameters
- container
- QueryContainer
The query container to which to register the ingress point.
- streamEvents
- IObservable<TPayload>
A sequence of stream events created by the client.
- startEdgeExtractor
- Expression<Func<TPayload,Int64>>
An expresion that describes how to interpret the start time for each data value.
- onCompletedPolicy
- OnCompletedPolicy
How to handle the completion of a stream.
- periodicPunctuationPolicy
- PeriodicPunctuationPolicy
Whether to add periodic punctuations to the resulting stream.
- identifier
- String
If provided, a unique name to identify to point of ingress in the query.
Returns
An IStreamable that can be used in queries.
Exceptions
Throws an exception if an out-of-order stream event is encountered. Also, an exception is thrown if any payload is null.
Applies to
RegisterTemporalInput<TPayload>(QueryContainer, IObservable<TPayload>, Expression<Func<TPayload,Int64>>, OnCompletedPolicy, DisorderPolicy, PeriodicPunctuationPolicy, String)
Converts a sequence of data elements to an IStreamable, start-edge only.
The completion policy specifies what to do when the resulting stream completes.
The disorder policy specifies what to do with out of order events.
The punctuation policy specifies whether and how punctuations are created and injected
into the resulting stream. Since punctuations force output, this exposes a throughput/latency tradeoff.
public static Microsoft.StreamProcessing.IObservableIngressStreamable<TPayload> RegisterTemporalInput<TPayload> (this Microsoft.StreamProcessing.QueryContainer container, IObservable<TPayload> streamEvents, System.Linq.Expressions.Expression<Func<TPayload,long>> startEdgeExtractor, Microsoft.StreamProcessing.OnCompletedPolicy onCompletedPolicy, Microsoft.StreamProcessing.DisorderPolicy disorderPolicy = null, Microsoft.StreamProcessing.PeriodicPunctuationPolicy periodicPunctuationPolicy = null, string identifier = null);static member RegisterTemporalInput : Microsoft.StreamProcessing.QueryContainer * IObservable<'Payload> * System.Linq.Expressions.Expression<Func<'Payload, int64>> * Microsoft.StreamProcessing.OnCompletedPolicy * Microsoft.StreamProcessing.DisorderPolicy * Microsoft.StreamProcessing.PeriodicPunctuationPolicy * string -> Microsoft.StreamProcessing.IObservableIngressStreamable<'Payload>Type Parameters
- TPayload
The type of data for the stream.
Parameters
- container
- QueryContainer
The query container to which to register the ingress point.
- streamEvents
- IObservable<TPayload>
A sequence of stream events created by the client.
- startEdgeExtractor
- Expression<Func<TPayload,Int64>>
An expresion that describes how to interpret the start time for each data value.
- onCompletedPolicy
- OnCompletedPolicy
How to handle the completion of a stream.
- disorderPolicy
- DisorderPolicy
How to handle events that are not in time order.
- periodicPunctuationPolicy
- PeriodicPunctuationPolicy
Whether to add periodic punctuations to the resulting stream.
- identifier
- String
If provided, a unique name to identify to point of ingress in the query.
Returns
An IStreamable that can be used in queries.
Exceptions
Throws an exception if the disorderPolicy is to throw and
an out-of-order stream event is encountered.
Also, an exception is thrown if any payload is null.
Applies to
RegisterTemporalInput<TPayload>(QueryContainer, IObservable<TPayload>, Expression<Func<TPayload,Int64>>, Expression<Func<TPayload,Int64>>, OnCompletedPolicy, PeriodicPunctuationPolicy, String)
Converts a sequence of data elements to an IStreamable, intervals and start-edges only.
The completion policy specifies what to do when the resulting stream completes.
The disorder policy specifies what to do with out of order events.
The punctuation policy specifies whether and how punctuations are created and injected
into the resulting stream. Since punctuations force output, this exposes a throughput/latency tradeoff.
public static Microsoft.StreamProcessing.IObservableIngressStreamable<TPayload> RegisterTemporalInput<TPayload> (this Microsoft.StreamProcessing.QueryContainer container, IObservable<TPayload> streamEvents, System.Linq.Expressions.Expression<Func<TPayload,long>> startEdgeExtractor, System.Linq.Expressions.Expression<Func<TPayload,long>> endEdgeExtractor, Microsoft.StreamProcessing.OnCompletedPolicy onCompletedPolicy, Microsoft.StreamProcessing.PeriodicPunctuationPolicy periodicPunctuationPolicy, string identifier = null);static member RegisterTemporalInput : Microsoft.StreamProcessing.QueryContainer * IObservable<'Payload> * System.Linq.Expressions.Expression<Func<'Payload, int64>> * System.Linq.Expressions.Expression<Func<'Payload, int64>> * Microsoft.StreamProcessing.OnCompletedPolicy * Microsoft.StreamProcessing.PeriodicPunctuationPolicy * string -> Microsoft.StreamProcessing.IObservableIngressStreamable<'Payload>Type Parameters
- TPayload
The type of data for the stream.
Parameters
- container
- QueryContainer
The query container to which to register the ingress point.
- streamEvents
- IObservable<TPayload>
A sequence of stream events created by the client.
- startEdgeExtractor
- Expression<Func<TPayload,Int64>>
An expresion that describes how to interpret the start time for each data value.
- endEdgeExtractor
- Expression<Func<TPayload,Int64>>
An expresion that describes how to interpret the end time for each data value. Return StreamEvent.InfinitySyncTime to indicate an event with no end time.
- onCompletedPolicy
- OnCompletedPolicy
How to handle the completion of a stream.
- periodicPunctuationPolicy
- PeriodicPunctuationPolicy
Whether to add periodic punctuations to the resulting stream.
- identifier
- String
If provided, a unique name to identify to point of ingress in the query.
Returns
An IStreamable that can be used in queries.
Exceptions
Throws an exception if an out-of-order stream event is encountered. Also, an exception is thrown if any payload is null.
Applies to
RegisterTemporalInput<TPayload>(QueryContainer, IObservable<TPayload>, Expression<Func<TPayload,Int64>>, Expression<Func<TPayload,Int64>>, OnCompletedPolicy, DisorderPolicy, PeriodicPunctuationPolicy, String)
Converts a sequence of data elements to an IStreamable, intervals and start-edges only.
The completion policy specifies what to do when the resulting stream completes.
The disorder policy specifies what to do with out of order events.
The punctuation policy specifies whether and how punctuations are created and injected
into the resulting stream. Since punctuations force output, this exposes a throughput/latency tradeoff.
public static Microsoft.StreamProcessing.IObservableIngressStreamable<TPayload> RegisterTemporalInput<TPayload> (this Microsoft.StreamProcessing.QueryContainer container, IObservable<TPayload> streamEvents, System.Linq.Expressions.Expression<Func<TPayload,long>> startEdgeExtractor, System.Linq.Expressions.Expression<Func<TPayload,long>> endEdgeExtractor, Microsoft.StreamProcessing.OnCompletedPolicy onCompletedPolicy, Microsoft.StreamProcessing.DisorderPolicy disorderPolicy = null, Microsoft.StreamProcessing.PeriodicPunctuationPolicy periodicPunctuationPolicy = null, string identifier = null);static member RegisterTemporalInput : Microsoft.StreamProcessing.QueryContainer * IObservable<'Payload> * System.Linq.Expressions.Expression<Func<'Payload, int64>> * System.Linq.Expressions.Expression<Func<'Payload, int64>> * Microsoft.StreamProcessing.OnCompletedPolicy * Microsoft.StreamProcessing.DisorderPolicy * Microsoft.StreamProcessing.PeriodicPunctuationPolicy * string -> Microsoft.StreamProcessing.IObservableIngressStreamable<'Payload>Type Parameters
- TPayload
The type of data for the stream.
Parameters
- container
- QueryContainer
The query container to which to register the ingress point.
- streamEvents
- IObservable<TPayload>
A sequence of stream events created by the client.
- startEdgeExtractor
- Expression<Func<TPayload,Int64>>
An expresion that describes how to interpret the start time for each data value.
- endEdgeExtractor
- Expression<Func<TPayload,Int64>>
An expresion that describes how to interpret the end time for each data value. Return StreamEvent.InfinitySyncTime to indicate an event with no end time.
- onCompletedPolicy
- OnCompletedPolicy
How to handle the completion of a stream.
- disorderPolicy
- DisorderPolicy
How to handle events that are not in time order.
- periodicPunctuationPolicy
- PeriodicPunctuationPolicy
Whether to add periodic punctuations to the resulting stream.
- identifier
- String
If provided, a unique name to identify to point of ingress in the query.
Returns
An IStreamable that can be used in queries.
Exceptions
Throws an exception if the disorderPolicy is to throw and
an out-of-order stream event is encountered.
Also, an exception is thrown if any payload is null.