Streamable.RegisterPartitionedArrayInput 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
RegisterPartitionedArrayInput<TPartitionKey,TPayload>(QueryContainer, IObservable<ArraySegment<TPayload>>, Expression<Func<TPayload, TPartitionKey>>, Expression<Func<TPayload,Int64>>, OnCompletedPolicy, String) |
Converts a sequence of data elements to an IStreamable, start-edge only, with a partition key.
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 |
RegisterPartitionedArrayInput<TPartitionKey,TPayload>(QueryContainer, IObservable<ArraySegment<TPayload>>, Expression<Func<TPayload, TPartitionKey>>, Expression<Func<TPayload,Int64>>, Expression<Func<TPayload, Int64>>, OnCompletedPolicy, String) |
Converts a sequence of data elements to an IStreamable, intervals and start-edges only, with a partition key.
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 |
RegisterPartitionedArrayInput<TPartitionKey,TPayload>(QueryContainer, IObservable<ArraySegment<TPayload>>, Expression<Func<TPayload, TPartitionKey>>, Expression<Func<TPayload,Int64>>, OnCompletedPolicy, String)
Converts a sequence of data elements to an IStreamable, start-edge only, with a partition key.
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.IPartitionedIngressStreamable<TPartitionKey,TPayload> RegisterPartitionedArrayInput<TPartitionKey,TPayload> (this Microsoft.StreamProcessing.QueryContainer container, IObservable<ArraySegment<TPayload>> streamEvents, System.Linq.Expressions.Expression<Func<TPayload,TPartitionKey>> partitionExtractor, System.Linq.Expressions.Expression<Func<TPayload,long>> startEdgeExtractor, Microsoft.StreamProcessing.OnCompletedPolicy onCompletedPolicy, string identifier = null);
static member RegisterPartitionedArrayInput : Microsoft.StreamProcessing.QueryContainer * IObservable<ArraySegment<'Payload>> * System.Linq.Expressions.Expression<Func<'Payload, 'PartitionKey>> * System.Linq.Expressions.Expression<Func<'Payload, int64>> * Microsoft.StreamProcessing.OnCompletedPolicy * string -> Microsoft.StreamProcessing.IPartitionedIngressStreamable<'PartitionKey, 'Payload>
Type Parameters
- TPartitionKey
The type of partition key for the stream.
- TPayload
The type of data for the stream.
Parameters
- container
- QueryContainer
The query container to which to register the ingress point.
- streamEvents
- IObservable<ArraySegment<TPayload>>
A sequence of stream events created by the client.
- partitionExtractor
- Expression<Func<TPayload,TPartitionKey>>
An expresion that describes how to interpret the partition identifier for each data value.
- 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.
- 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
RegisterPartitionedArrayInput<TPartitionKey,TPayload>(QueryContainer, IObservable<ArraySegment<TPayload>>, Expression<Func<TPayload, TPartitionKey>>, Expression<Func<TPayload,Int64>>, Expression<Func<TPayload, Int64>>, OnCompletedPolicy, String)
Converts a sequence of data elements to an IStreamable, intervals and start-edges only, with a partition key.
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.IPartitionedIngressStreamable<TPartitionKey,TPayload> RegisterPartitionedArrayInput<TPartitionKey,TPayload> (this Microsoft.StreamProcessing.QueryContainer container, IObservable<ArraySegment<TPayload>> streamEvents, System.Linq.Expressions.Expression<Func<TPayload,TPartitionKey>> partitionExtractor, System.Linq.Expressions.Expression<Func<TPayload,long>> startEdgeExtractor, System.Linq.Expressions.Expression<Func<TPayload,long>> endEdgeExtractor, Microsoft.StreamProcessing.OnCompletedPolicy onCompletedPolicy, string identifier = null);
static member RegisterPartitionedArrayInput : Microsoft.StreamProcessing.QueryContainer * IObservable<ArraySegment<'Payload>> * System.Linq.Expressions.Expression<Func<'Payload, 'PartitionKey>> * System.Linq.Expressions.Expression<Func<'Payload, int64>> * System.Linq.Expressions.Expression<Func<'Payload, int64>> * Microsoft.StreamProcessing.OnCompletedPolicy * string -> Microsoft.StreamProcessing.IPartitionedIngressStreamable<'PartitionKey, 'Payload>
Type Parameters
- TPartitionKey
The type of partition key for the stream.
- TPayload
The type of data for the stream.
Parameters
- container
- QueryContainer
The query container to which to register the ingress point.
- streamEvents
- IObservable<ArraySegment<TPayload>>
A sequence of stream events created by the client.
- partitionExtractor
- Expression<Func<TPayload,TPartitionKey>>
An expresion that describes how to interpret the partition identifier for each data value.
- 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.
- 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.