Streamable.ToPartitionedArrayStreamable 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
| ToPartitionedArrayStreamable<TPartitionKey,TPayload>(IObservable<ArraySegment<TPayload>>, Expression<Func<TPayload,TPartitionKey>>, Expression<Func<TPayload, Int64>>, Expression<Func<TPayload,Int64>>, OnCompletedPolicy) |
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 |
| ToPartitionedArrayStreamable<TPartitionKey,TPayload>(IObservable<ArraySegment<TPayload>>, Expression<Func<TPayload,TPartitionKey>>, Expression<Func<TPayload, Int64>>, OnCompletedPolicy) |
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 |
ToPartitionedArrayStreamable<TPartitionKey,TPayload>(IObservable<ArraySegment<TPayload>>, Expression<Func<TPayload,TPartitionKey>>, Expression<Func<TPayload, Int64>>, Expression<Func<TPayload,Int64>>, OnCompletedPolicy)
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> ToPartitionedArrayStreamable<TPartitionKey,TPayload> (this 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);static member ToPartitionedArrayStreamable : 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 -> 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
- 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.
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
ToPartitionedArrayStreamable<TPartitionKey,TPayload>(IObservable<ArraySegment<TPayload>>, Expression<Func<TPayload,TPartitionKey>>, Expression<Func<TPayload, Int64>>, OnCompletedPolicy)
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> ToPartitionedArrayStreamable<TPartitionKey,TPayload> (this IObservable<ArraySegment<TPayload>> streamEvents, System.Linq.Expressions.Expression<Func<TPayload,TPartitionKey>> partitionExtractor, System.Linq.Expressions.Expression<Func<TPayload,long>> startEdgeExtractor, Microsoft.StreamProcessing.OnCompletedPolicy onCompletedPolicy);static member ToPartitionedArrayStreamable : IObservable<ArraySegment<'Payload>> * System.Linq.Expressions.Expression<Func<'Payload, 'PartitionKey>> * System.Linq.Expressions.Expression<Func<'Payload, int64>> * Microsoft.StreamProcessing.OnCompletedPolicy -> 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
- 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.
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.