Streamable.RegisterPartitionedInput Method

Definition

Namespace:

Microsoft.StreamProcessing

Assembly:

Microsoft.StreamProcessing.dll

Overloads

RegisterPartitionedInput<TPartitionKey,TPayload>(QueryContainer, IObservable<TPayload>, Expression<Func<TPayload,TPartitionKey>>, Expression<Func<TPayload,Int64>>, OnCompletedPolicy, PartitionedPeriodicPunctuationPolicy, 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.
RegisterPartitionedInput<TPartitionKey,TPayload>(QueryContainer, IObservable<TPayload>, Expression<Func<TPayload,TPartitionKey>>, Expression<Func<TPayload,Int64>>, OnCompletedPolicy, PartitionedDisorderPolicy, PartitionedPeriodicPunctuationPolicy, 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.
RegisterPartitionedInput<TPartitionKey,TPayload>(QueryContainer, IObservable<TPayload>, Expression<Func<TPayload,TPartitionKey>>, Expression<Func<TPayload,Int64>>, Expression<Func<TPayload,Int64>>, OnCompletedPolicy, PartitionedPeriodicPunctuationPolicy, 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.
RegisterPartitionedInput<TPartitionKey,TPayload>(QueryContainer, IObservable<TPayload>, Expression<Func<TPayload,TPartitionKey>>, Expression<Func<TPayload,Int64>>, Expression<Func<TPayload,Int64>>, OnCompletedPolicy, PartitionedDisorderPolicy, PartitionedPeriodicPunctuationPolicy, 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.

RegisterPartitionedInput<TPartitionKey,TPayload>(QueryContainer, IObservable<TPayload>, Expression<Func<TPayload,TPartitionKey>>, Expression<Func<TPayload,Int64>>, OnCompletedPolicy, PartitionedPeriodicPunctuationPolicy, 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> RegisterPartitionedInput<TPartitionKey,TPayload> (this Microsoft.StreamProcessing.QueryContainer container, 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, string identifier = null);

static member RegisterPartitionedInput : Microsoft.StreamProcessing.QueryContainer * IObservable<'Payload> * System.Linq.Expressions.Expression<Func<'Payload, 'PartitionKey>> * System.Linq.Expressions.Expression<Func<'Payload, int64>> * Microsoft.StreamProcessing.OnCompletedPolicy * Microsoft.StreamProcessing.PartitionedPeriodicPunctuationPolicy * 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<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.

identifier

String

If provided, a unique name to identify to point of ingress in the query.

Returns

IPartitionedIngressStreamable<TPartitionKey,TPayload>

An IStreamable that can be used in queries.

Exceptions

IngressException

Throws an exception if an out-of-order stream event is encountered. Also, an exception is thrown if any payload is null.

RegisterPartitionedInput<TPartitionKey,TPayload>(QueryContainer, IObservable<TPayload>, Expression<Func<TPayload,TPartitionKey>>, Expression<Func<TPayload,Int64>>, OnCompletedPolicy, PartitionedDisorderPolicy, PartitionedPeriodicPunctuationPolicy, 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> RegisterPartitionedInput<TPartitionKey,TPayload> (this Microsoft.StreamProcessing.QueryContainer container, 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, string identifier = null);

static member RegisterPartitionedInput : Microsoft.StreamProcessing.QueryContainer * 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 * 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<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.

identifier

String

If provided, a unique name to identify to point of ingress in the query.

Returns

IPartitionedIngressStreamable<TPartitionKey,TPayload>

An IStreamable that can be used in queries.

Exceptions

IngressException

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.

RegisterPartitionedInput<TPartitionKey,TPayload>(QueryContainer, IObservable<TPayload>, Expression<Func<TPayload,TPartitionKey>>, Expression<Func<TPayload,Int64>>, Expression<Func<TPayload,Int64>>, OnCompletedPolicy, PartitionedPeriodicPunctuationPolicy, 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> RegisterPartitionedInput<TPartitionKey,TPayload> (this Microsoft.StreamProcessing.QueryContainer container, 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, string identifier = null);

static member RegisterPartitionedInput : Microsoft.StreamProcessing.QueryContainer * 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 * 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<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.

identifier

String

If provided, a unique name to identify to point of ingress in the query.

Returns

IPartitionedIngressStreamable<TPartitionKey,TPayload>

An IStreamable that can be used in queries.

Exceptions

IngressException

Throws an exception if an out-of-order stream event is encountered. Also, an exception is thrown if any payload is null.

RegisterPartitionedInput<TPartitionKey,TPayload>(QueryContainer, IObservable<TPayload>, Expression<Func<TPayload,TPartitionKey>>, Expression<Func<TPayload,Int64>>, Expression<Func<TPayload,Int64>>, OnCompletedPolicy, PartitionedDisorderPolicy, PartitionedPeriodicPunctuationPolicy, 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> RegisterPartitionedInput<TPartitionKey,TPayload> (this Microsoft.StreamProcessing.QueryContainer container, 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, string identifier = null);

static member RegisterPartitionedInput : Microsoft.StreamProcessing.QueryContainer * 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 * 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<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.

identifier

String

If provided, a unique name to identify to point of ingress in the query.

Returns

IPartitionedIngressStreamable<TPartitionKey,TPayload>

An IStreamable that can be used in queries.

Exceptions

IngressException

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.