Streamable.RegisterTemporalOutput 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
| RegisterTemporalOutput<TKey,TPayload,TResult>(QueryContainer, IStreamable<PartitionKey<TKey>,TPayload>, Expression<Func<TKey, Int64,TPayload,TResult>>, String) |
Exports a streamable as an observable of events. Produces events that are sync time ordered. Expects only start-edge events in the stream, and constructs user-defined payloads as a result. |
| RegisterTemporalOutput<TKey,TPayload,TResult>(QueryContainer, IStreamable<PartitionKey<TKey>,TPayload>, Expression<Func<TKey, Int64,Int64,TPayload,TResult>>, String) |
Exports a streamable as an observable of events. Produces events that are sync time ordered. Expects only start-edge and interval events in the stream, and constructs user-defined payloads as a result. |
| RegisterTemporalOutput<TPayload,TResult>(QueryContainer, IStreamable<Empty,TPayload>, Expression<Func<Int64,Int64,TPayload,TResult>>, String) |
Exports a streamable as an observable of events. Produces events that are sync time ordered. Expects only start-edge and interval events in the stream, and constructs user-defined payloads as a result. |
| RegisterTemporalOutput<TPayload,TResult>(QueryContainer, IStreamable<Empty,TPayload>, Expression<Func<Int64,TPayload,TResult>>, String) |
Exports a streamable as an observable of events. Produces events that are sync time ordered. Expects only start-edge events in the stream, and constructs user-defined payloads as a result. |
RegisterTemporalOutput<TKey,TPayload,TResult>(QueryContainer, IStreamable<PartitionKey<TKey>,TPayload>, Expression<Func<TKey, Int64,TPayload,TResult>>, String)
Exports a streamable as an observable of events. Produces events that are sync time ordered. Expects only start-edge events in the stream, and constructs user-defined payloads as a result.
public static IObservable<TResult> RegisterTemporalOutput<TKey,TPayload,TResult> (this Microsoft.StreamProcessing.QueryContainer container, Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.PartitionKey<TKey>,TPayload> stream, System.Linq.Expressions.Expression<Func<TKey,long,TPayload,TResult>> constructor, string identifier = null);static member RegisterTemporalOutput : Microsoft.StreamProcessing.QueryContainer * Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.PartitionKey<'Key>, 'Payload> * System.Linq.Expressions.Expression<Func<'Key, int64, 'Payload, 'Result>> * string -> IObservable<'Result><Extension()>
Public Function RegisterTemporalOutput(Of TKey, TPayload, TResult) (container As QueryContainer, stream As IStreamable(Of PartitionKey(Of TKey), TPayload), constructor As Expression(Of Func(Of TKey, Long, TPayload, TResult)), Optional identifier As String = null) As IObservable(Of TResult)Type Parameters
- TKey
- TPayload
- TResult
Parameters
- container
- QueryContainer
The query container to which an egress point is being added.
- stream
- IStreamable<Microsoft.StreamProcessing.PartitionKey<TKey>,TPayload>
- constructor
- Expression<Func<TKey,Int64,TPayload,TResult>>
Method description that constructs result data from the start time and the payload of each event.
- identifier
- String
A string that can uniquely identify the point of egress in the query.
Returns
Applies to
RegisterTemporalOutput<TKey,TPayload,TResult>(QueryContainer, IStreamable<PartitionKey<TKey>,TPayload>, Expression<Func<TKey, Int64,Int64,TPayload,TResult>>, String)
Exports a streamable as an observable of events. Produces events that are sync time ordered. Expects only start-edge and interval events in the stream, and constructs user-defined payloads as a result.
public static IObservable<TResult> RegisterTemporalOutput<TKey,TPayload,TResult> (this Microsoft.StreamProcessing.QueryContainer container, Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.PartitionKey<TKey>,TPayload> stream, System.Linq.Expressions.Expression<Func<TKey,long,long,TPayload,TResult>> constructor, string identifier = null);static member RegisterTemporalOutput : Microsoft.StreamProcessing.QueryContainer * Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.PartitionKey<'Key>, 'Payload> * System.Linq.Expressions.Expression<Func<'Key, int64, int64, 'Payload, 'Result>> * string -> IObservable<'Result><Extension()>
Public Function RegisterTemporalOutput(Of TKey, TPayload, TResult) (container As QueryContainer, stream As IStreamable(Of PartitionKey(Of TKey), TPayload), constructor As Expression(Of Func(Of TKey, Long, Long, TPayload, TResult)), Optional identifier As String = null) As IObservable(Of TResult)Type Parameters
- TKey
- TPayload
- TResult
Parameters
- container
- QueryContainer
The query container to which an egress point is being added.
- stream
- IStreamable<Microsoft.StreamProcessing.PartitionKey<TKey>,TPayload>
- constructor
- Expression<Func<TKey,Int64,Int64,TPayload,TResult>>
Method description that constructs result data from the start time, end time, and the payload of each event.
- identifier
- String
A string that can uniquely identify the point of egress in the query.
Returns
Applies to
RegisterTemporalOutput<TPayload,TResult>(QueryContainer, IStreamable<Empty,TPayload>, Expression<Func<Int64,Int64,TPayload,TResult>>, String)
Exports a streamable as an observable of events. Produces events that are sync time ordered. Expects only start-edge and interval events in the stream, and constructs user-defined payloads as a result.
public static IObservable<TResult> RegisterTemporalOutput<TPayload,TResult> (this Microsoft.StreamProcessing.QueryContainer container, Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty,TPayload> stream, System.Linq.Expressions.Expression<Func<long,long,TPayload,TResult>> constructor, string identifier = null);static member RegisterTemporalOutput : Microsoft.StreamProcessing.QueryContainer * Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty, 'Payload> * System.Linq.Expressions.Expression<Func<int64, int64, 'Payload, 'Result>> * string -> IObservable<'Result><Extension()>
Public Function RegisterTemporalOutput(Of TPayload, TResult) (container As QueryContainer, stream As IStreamable(Of Empty, TPayload), constructor As Expression(Of Func(Of Long, Long, TPayload, TResult)), Optional identifier As String = null) As IObservable(Of TResult)Type Parameters
- TPayload
- TResult
Parameters
- container
- QueryContainer
The query container to which an egress point is being added.
- stream
- IStreamable<Empty,TPayload>
- constructor
- Expression<Func<Int64,Int64,TPayload,TResult>>
Method description that constructs result data from the start time, end time, and the payload of each event.
- identifier
- String
A string that can uniquely identify the point of egress in the query.
Returns
Applies to
RegisterTemporalOutput<TPayload,TResult>(QueryContainer, IStreamable<Empty,TPayload>, Expression<Func<Int64,TPayload,TResult>>, String)
Exports a streamable as an observable of events. Produces events that are sync time ordered. Expects only start-edge events in the stream, and constructs user-defined payloads as a result.
public static IObservable<TResult> RegisterTemporalOutput<TPayload,TResult> (this Microsoft.StreamProcessing.QueryContainer container, Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty,TPayload> stream, System.Linq.Expressions.Expression<Func<long,TPayload,TResult>> constructor, string identifier = null);static member RegisterTemporalOutput : Microsoft.StreamProcessing.QueryContainer * Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty, 'Payload> * System.Linq.Expressions.Expression<Func<int64, 'Payload, 'Result>> * string -> IObservable<'Result><Extension()>
Public Function RegisterTemporalOutput(Of TPayload, TResult) (container As QueryContainer, stream As IStreamable(Of Empty, TPayload), constructor As Expression(Of Func(Of Long, TPayload, TResult)), Optional identifier As String = null) As IObservable(Of TResult)Type Parameters
- TPayload
- TResult
Parameters
- container
- QueryContainer
The query container to which an egress point is being added.
- stream
- IStreamable<Empty,TPayload>
- constructor
- Expression<Func<Int64,TPayload,TResult>>
Method description that constructs result data from the start time and the payload of each event.
- identifier
- String
A string that can uniquely identify the point of egress in the query.