Streamable.RegisterArrayOutput 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
| RegisterArrayOutput<TKey,TPayload>(QueryContainer, IStreamable<PartitionKey<TKey>,TPayload>, ReshapingPolicy, String) |
Exports a streamable as an observable of events. Produces events that are sync time ordered. |
| RegisterArrayOutput<TKey,TPayload>(QueryContainer, IStreamable<PartitionKey<TKey>, TPayload>, Func<PartitionedStreamEvent<TKey,TPayload>[]>, ReshapingPolicy, String) |
Exports a streamable as an observable of events. Produces events that are sync time ordered. |
| RegisterArrayOutput<TPayload>(QueryContainer, IStreamable<Empty,TPayload>, ReshapingPolicy, String) |
Exports a streamable as an observable of events. Produces events that are sync time ordered. |
| RegisterArrayOutput<TPayload>(QueryContainer, IStreamable<Empty,TPayload>, Func<StreamEvent<TPayload>[]>, ReshapingPolicy, String) |
Exports a streamable as an observable of events. Produces events that are sync time ordered. |
RegisterArrayOutput<TKey,TPayload>(QueryContainer, IStreamable<PartitionKey<TKey>,TPayload>, ReshapingPolicy, String)
Exports a streamable as an observable of events. Produces events that are sync time ordered.
public static IObservable<ArraySegment<Microsoft.StreamProcessing.PartitionedStreamEvent<TKey,TPayload>>> RegisterArrayOutput<TKey,TPayload> (this Microsoft.StreamProcessing.QueryContainer container, Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.PartitionKey<TKey>,TPayload> stream, Microsoft.StreamProcessing.ReshapingPolicy reshapingPolicy = null, string identifier = null);static member RegisterArrayOutput : Microsoft.StreamProcessing.QueryContainer * Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.PartitionKey<'Key>, 'Payload> * Microsoft.StreamProcessing.ReshapingPolicy * string -> IObservable<ArraySegment<Microsoft.StreamProcessing.PartitionedStreamEvent<'Key, 'Payload>>>Type Parameters
- TKey
- TPayload
Parameters
- container
- QueryContainer
The query container to which an egress point is being added.
- stream
- IStreamable<Microsoft.StreamProcessing.PartitionKey<TKey>,TPayload>
- reshapingPolicy
- ReshapingPolicy
Policy that specifies whether and how events are reshaped at egress. Default passes events through unmodified.
- identifier
- String
A string that can uniquely identify the point of egress in the query.
Returns
Applies to
RegisterArrayOutput<TKey,TPayload>(QueryContainer, IStreamable<PartitionKey<TKey>, TPayload>, Func<PartitionedStreamEvent<TKey,TPayload>[]>, ReshapingPolicy, String)
Exports a streamable as an observable of events. Produces events that are sync time ordered.
public static IObservable<ArraySegment<Microsoft.StreamProcessing.PartitionedStreamEvent<TKey,TPayload>>> RegisterArrayOutput<TKey,TPayload> (this Microsoft.StreamProcessing.QueryContainer container, Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.PartitionKey<TKey>,TPayload> stream, Func<Microsoft.StreamProcessing.PartitionedStreamEvent<TKey,TPayload>[]> generator, Microsoft.StreamProcessing.ReshapingPolicy reshapingPolicy = null, string identifier = null);static member RegisterArrayOutput : Microsoft.StreamProcessing.QueryContainer * Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.PartitionKey<'Key>, 'Payload> * Func<Microsoft.StreamProcessing.PartitionedStreamEvent<'Key, 'Payload>[]> * Microsoft.StreamProcessing.ReshapingPolicy * string -> IObservable<ArraySegment<Microsoft.StreamProcessing.PartitionedStreamEvent<'Key, 'Payload>>>Type Parameters
- TKey
- TPayload
Parameters
- container
- QueryContainer
The query container to which an egress point is being added.
- stream
- IStreamable<Microsoft.StreamProcessing.PartitionKey<TKey>,TPayload>
- generator
- Func<PartitionedStreamEvent<TKey,TPayload>[]>
A function that returns an array that will be populated with stream results.
- reshapingPolicy
- ReshapingPolicy
Policy that specifies whether and how events are reshaped at egress. Default passes events through unmodified.
- identifier
- String
A string that can uniquely identify the point of egress in the query.
Returns
Applies to
RegisterArrayOutput<TPayload>(QueryContainer, IStreamable<Empty,TPayload>, ReshapingPolicy, String)
Exports a streamable as an observable of events. Produces events that are sync time ordered.
public static IObservable<ArraySegment<Microsoft.StreamProcessing.StreamEvent<TPayload>>> RegisterArrayOutput<TPayload> (this Microsoft.StreamProcessing.QueryContainer container, Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty,TPayload> stream, Microsoft.StreamProcessing.ReshapingPolicy reshapingPolicy = null, string identifier = null);static member RegisterArrayOutput : Microsoft.StreamProcessing.QueryContainer * Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty, 'Payload> * Microsoft.StreamProcessing.ReshapingPolicy * string -> IObservable<ArraySegment<Microsoft.StreamProcessing.StreamEvent<'Payload>>>Type Parameters
- TPayload
Parameters
- container
- QueryContainer
The query container to which an egress point is being added.
- stream
- IStreamable<Empty,TPayload>
- reshapingPolicy
- ReshapingPolicy
Policy that specifies whether and how events are reshaped at egress. Default passes events through unmodified.
- identifier
- String
A string that can uniquely identify the point of egress in the query.
Returns
Applies to
RegisterArrayOutput<TPayload>(QueryContainer, IStreamable<Empty,TPayload>, Func<StreamEvent<TPayload>[]>, ReshapingPolicy, String)
Exports a streamable as an observable of events. Produces events that are sync time ordered.
public static IObservable<ArraySegment<Microsoft.StreamProcessing.StreamEvent<TPayload>>> RegisterArrayOutput<TPayload> (this Microsoft.StreamProcessing.QueryContainer container, Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty,TPayload> stream, Func<Microsoft.StreamProcessing.StreamEvent<TPayload>[]> generator, Microsoft.StreamProcessing.ReshapingPolicy reshapingPolicy = null, string identifier = null);static member RegisterArrayOutput : Microsoft.StreamProcessing.QueryContainer * Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty, 'Payload> * Func<Microsoft.StreamProcessing.StreamEvent<'Payload>[]> * Microsoft.StreamProcessing.ReshapingPolicy * string -> IObservable<ArraySegment<Microsoft.StreamProcessing.StreamEvent<'Payload>>>Type Parameters
- TPayload
Parameters
- container
- QueryContainer
The query container to which an egress point is being added.
- stream
- IStreamable<Empty,TPayload>
- generator
- Func<StreamEvent<TPayload>[]>
A function that returns an array that will be populated with stream results.
- reshapingPolicy
- ReshapingPolicy
Policy that specifies whether and how events are reshaped at egress. Default passes events through unmodified.
- identifier
- String
A string that can uniquely identify the point of egress in the query.