Streamable.ToPartitionedStreamable 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
ToPartitionedStreamable<TPartitionKey,TPayload>(IObservable<TPayload>, Expression<Func<TPayload,TPartitionKey>>, Expression<Func<TPayload, Int64>>, Expression<Func<TPayload,Int64>>, OnCompletedPolicy, PartitionedPeriodicPunctuationPolicy) |
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 |
ToPartitionedStreamable<TPartitionKey,TPayload>(IObservable<TPayload>, Expression<Func<TPayload,TPartitionKey>>, Expression<Func<TPayload, Int64>>, Expression<Func<TPayload,Int64>>, OnCompletedPolicy, PartitionedDisorderPolicy, PartitionedPeriodicPunctuationPolicy) |
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 |
ToPartitionedStreamable<TPartitionKey,TPayload>(IObservable<TPayload>, Expression<Func<TPayload,TPartitionKey>>, Expression<Func<TPayload, Int64>>, OnCompletedPolicy, PartitionedPeriodicPunctuationPolicy) |
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 |
ToPartitionedStreamable<TPartitionKey,TPayload>(IObservable<TPayload>, Expression<Func<TPayload,TPartitionKey>>, Expression<Func<TPayload, Int64>>, OnCompletedPolicy, PartitionedDisorderPolicy, PartitionedPeriodicPunctuationPolicy) |
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 |
ToPartitionedStreamable<TPartitionKey,TPayload>(IObservable<TPayload>, Expression<Func<TPayload,TPartitionKey>>, Expression<Func<TPayload, Int64>>, Expression<Func<TPayload,Int64>>, OnCompletedPolicy, PartitionedPeriodicPunctuationPolicy)
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> ToPartitionedStreamable<TPartitionKey,TPayload> (this IObservable<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, Microsoft.StreamProcessing.PartitionedPeriodicPunctuationPolicy periodicPunctuationPolicy);
static member ToPartitionedStreamable : IObservable<'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.PartitionedPeriodicPunctuationPolicy -> 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<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.
- periodicPunctuationPolicy
- PartitionedPeriodicPunctuationPolicy
Whether to add periodic punctuations to the resulting 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
ToPartitionedStreamable<TPartitionKey,TPayload>(IObservable<TPayload>, Expression<Func<TPayload,TPartitionKey>>, Expression<Func<TPayload, Int64>>, Expression<Func<TPayload,Int64>>, OnCompletedPolicy, PartitionedDisorderPolicy, PartitionedPeriodicPunctuationPolicy)
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> ToPartitionedStreamable<TPartitionKey,TPayload> (this IObservable<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, Microsoft.StreamProcessing.PartitionedDisorderPolicy disorderPolicy = null, Microsoft.StreamProcessing.PartitionedPeriodicPunctuationPolicy periodicPunctuationPolicy = null);
static member ToPartitionedStreamable : IObservable<'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.PartitionedDisorderPolicy * Microsoft.StreamProcessing.PartitionedPeriodicPunctuationPolicy -> 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<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.
- disorderPolicy
- PartitionedDisorderPolicy
How to handle events that are not in time order.
- periodicPunctuationPolicy
- PartitionedPeriodicPunctuationPolicy
Whether to add periodic punctuations to the resulting stream.
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
ToPartitionedStreamable<TPartitionKey,TPayload>(IObservable<TPayload>, Expression<Func<TPayload,TPartitionKey>>, Expression<Func<TPayload, Int64>>, OnCompletedPolicy, PartitionedPeriodicPunctuationPolicy)
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> ToPartitionedStreamable<TPartitionKey,TPayload> (this IObservable<TPayload> streamEvents, System.Linq.Expressions.Expression<Func<TPayload,TPartitionKey>> partitionExtractor, System.Linq.Expressions.Expression<Func<TPayload,long>> startEdgeExtractor, Microsoft.StreamProcessing.OnCompletedPolicy onCompletedPolicy, Microsoft.StreamProcessing.PartitionedPeriodicPunctuationPolicy periodicPunctuationPolicy);
static member ToPartitionedStreamable : IObservable<'Payload> * System.Linq.Expressions.Expression<Func<'Payload, 'PartitionKey>> * System.Linq.Expressions.Expression<Func<'Payload, int64>> * Microsoft.StreamProcessing.OnCompletedPolicy * Microsoft.StreamProcessing.PartitionedPeriodicPunctuationPolicy -> 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<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.
- periodicPunctuationPolicy
- PartitionedPeriodicPunctuationPolicy
Whether to add periodic punctuations to the resulting 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
ToPartitionedStreamable<TPartitionKey,TPayload>(IObservable<TPayload>, Expression<Func<TPayload,TPartitionKey>>, Expression<Func<TPayload, Int64>>, OnCompletedPolicy, PartitionedDisorderPolicy, PartitionedPeriodicPunctuationPolicy)
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> ToPartitionedStreamable<TPartitionKey,TPayload> (this IObservable<TPayload> streamEvents, System.Linq.Expressions.Expression<Func<TPayload,TPartitionKey>> partitionExtractor, System.Linq.Expressions.Expression<Func<TPayload,long>> startEdgeExtractor, Microsoft.StreamProcessing.OnCompletedPolicy onCompletedPolicy, Microsoft.StreamProcessing.PartitionedDisorderPolicy disorderPolicy = null, Microsoft.StreamProcessing.PartitionedPeriodicPunctuationPolicy periodicPunctuationPolicy = null);
static member ToPartitionedStreamable : IObservable<'Payload> * System.Linq.Expressions.Expression<Func<'Payload, 'PartitionKey>> * System.Linq.Expressions.Expression<Func<'Payload, int64>> * Microsoft.StreamProcessing.OnCompletedPolicy * Microsoft.StreamProcessing.PartitionedDisorderPolicy * Microsoft.StreamProcessing.PartitionedPeriodicPunctuationPolicy -> 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<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.
- disorderPolicy
- PartitionedDisorderPolicy
How to handle events that are not in time order.
- periodicPunctuationPolicy
- PartitionedPeriodicPunctuationPolicy
Whether to add periodic punctuations to the resulting stream.
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.