QueryContainer Class

Reference

Definition

Namespace:: Microsoft.StreamProcessing

Assembly:: Microsoft.StreamProcessing.Common.dll

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.

A container object that represents a stream query.

public class QueryContainer

type QueryContainer = class

Public Class QueryContainer

Inheritance: Object
QueryContainer

Constructors

QueryContainer()	Creates a new instance of a query container for use in checkpointable queries.
QueryContainer(Object)	Creates a new instance of a query container for use in checkpointable queries.

Properties

AvroSurrogate

IAvroSurrogate to be used in Trillium serialization in checkpoints and serialized StreamMessage for payload types which can not be serialized otherwise.

Methods

Restore(Stream)

Start a query, with or without a previously checkpointed state.

Extension Methods

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.
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.
RegisterAtemporalArrayInput<TPayload>(QueryContainer, IObservable<ArraySegment<TPayload>>, TimelinePolicy, OnCompletedPolicy, String)	Registers a data source to be used as input with the query container.
RegisterAtemporalArrayOutput<TPayload>(QueryContainer, IStreamable<Empty,TPayload>, Func<TPayload[]>, String)	Registers an IStreamable object as an output of a query, with output as a list of change events.
RegisterAtemporalArrayOutput<TPayload>(QueryContainer, IStreamable<Empty,TPayload>, String)	Registers an IStreamable object as an output of a query, with output as a list of change events.
RegisterAtemporalInput<TPayload>(QueryContainer, IObservable<TPayload>, TimelinePolicy, OnCompletedPolicy, String)	Registers a data source to be used as input with the query container.
RegisterAtemporalOutput<TPayload>(QueryContainer, IStreamable<Empty,TPayload>, String)	Registers an IStreamable object as an output of a query, with output as a list of change events.
RegisterBinaryInput<TPayload>(QueryContainer, Stream, IIngressScheduler, Boolean, StreamProperties<Empty,TPayload>, String)	Deserialize from binary stream to streamable
RegisterBinaryInput<TKey,TPayload>(QueryContainer, Stream, IIngressScheduler, Boolean, StreamProperties<TKey,TPayload>, String)	Deserialize from binary stream to streamable
RegisterBinaryInputFromFile<TPayload>(QueryContainer, String, Int32, IIngressScheduler, Boolean, StreamProperties<Empty,TPayload>, String)	Deserialize from binary stream to streamable
RegisterBinaryInputFromFile<TKey,TPayload>(QueryContainer, String, Int32, IIngressScheduler, Boolean, StreamProperties<TKey,TPayload>, String)	Deserialize from binary stream to streamable
RegisterBinaryInputPassive<TPayload>(QueryContainer, Stream, Boolean, StreamProperties<Empty,TPayload>, String)	Deserialize from binary stream to streamable
RegisterBinaryInputPassive<TKey,TPayload>(QueryContainer, Stream, Boolean, StreamProperties<TKey,TPayload>, String)	Deserialize from binary stream to streamable
RegisterBinaryInputPassiveFromFile<TPayload>(QueryContainer, String, Boolean, StreamProperties<Empty,TPayload>, String)	Deserialize from binary stream to streamable
RegisterBinaryInputPassiveFromFile<TKey,TPayload>(QueryContainer, String, Boolean, StreamProperties<TKey,TPayload>, String)	Deserialize from binary stream to streamable
RegisterBinaryOutput<TKey,TPayload>(QueryContainer, IStreamable<TKey,TPayload>, Stream, Boolean, String)	Serialize streamable into a binary stream
RegisterBinaryOutput<TKey,TPayload>(QueryContainer, IStreamable<TKey,TPayload>, String, String)	Serialize streamble into a binary file
RegisterInput<TPayload>(QueryContainer, IObservable<StreamEvent<TPayload>>, OnCompletedPolicy, DisorderPolicy, PeriodicPunctuationPolicy, String)	Converts a sequence of StreamEvents to an IStreamable. 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.
RegisterInput<TPayload>(QueryContainer, IObservable<StreamEvent<TPayload>>, OnCompletedPolicy, PeriodicPunctuationPolicy, String)	Converts a sequence of StreamEvents to an IStreamable. 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.
RegisterInput<TPayload>(QueryContainer, IObservable<ArraySegment<StreamEvent<TPayload>>>, OnCompletedPolicy, String)	Converts a sequence of StreamEvents to an IStreamable. 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.
RegisterInput<TPartitionKey,TPayload>(QueryContainer, IObservable<PartitionedStreamEvent<TPartitionKey, TPayload>>, OnCompletedPolicy, PartitionedDisorderPolicy, PartitionedPeriodicPunctuationPolicy, String)	Converts a sequence of PartitionedStreamEvents to an IStreamable. 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.
RegisterInput<TPartitionKey,TPayload>(QueryContainer, IObservable<PartitionedStreamEvent<TPartitionKey, TPayload>>, OnCompletedPolicy, PartitionedPeriodicPunctuationPolicy, String)	Converts a sequence of PartitionedStreamEvents to an IStreamable. 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.
RegisterInput<TPartitionKey,TPayload>(QueryContainer, IObservable<ArraySegment<PartitionedStreamEvent<TPartitionKey, TPayload>>>, OnCompletedPolicy, String)	Converts a sequence of PartitionedStreamEvents to an IStreamable. 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.
RegisterOutput<TPayload>(QueryContainer, IStreamable<Empty,TPayload>, ReshapingPolicy, String)	Exports a streamable as an observable of events. Produces events that are sync time ordered.
RegisterOutput<TKey,TPayload>(QueryContainer, IStreamable<PartitionKey<TKey>,TPayload>, ReshapingPolicy, String)	Exports a streamable as an observable of events. Produces events that are sync time ordered.
RegisterOutputAsEnumerable<TPayload>(QueryContainer, IStreamable<Empty,TPayload>, String)	Registers an IStreamable object as an output of a query, with output as a progressively changing enumerable.
RegisterPartitionedArrayInput<TPartitionKey,TPayload>(QueryContainer, IObservable<ArraySegment<TPayload>>, Expression<Func<TPayload, TPartitionKey>>, Expression<Func<TPayload,Int64>>, OnCompletedPolicy, 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.
RegisterPartitionedArrayInput<TPartitionKey,TPayload>(QueryContainer, IObservable<ArraySegment<TPayload>>, Expression<Func<TPayload, TPartitionKey>>, Expression<Func<TPayload,Int64>>, Expression<Func<TPayload, Int64>>, OnCompletedPolicy, 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, 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>>, 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>>, 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>>, 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.
RegisterTemporalArrayInput<TPayload>(QueryContainer, IObservable<ArraySegment<TPayload>>, Expression<Func<TPayload,Int64>>, OnCompletedPolicy, String)	Converts a sequence of data elements to an IStreamable, start-edge only. 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.
RegisterTemporalArrayInput<TPayload>(QueryContainer, IObservable<ArraySegment<TPayload>>, Expression<Func<TPayload,Int64>>, Expression<Func<TPayload,Int64>>, OnCompletedPolicy, String)	Converts a sequence of data elements to an IStreamable, intervals and start-edges only. 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.
RegisterTemporalArrayOutput<TPayload,TResult>(QueryContainer, IStreamable<Empty,TPayload>, Func<TResult[]>, 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.
RegisterTemporalArrayOutput<TPayload,TResult>(QueryContainer, IStreamable<Empty,TPayload>, Func<TResult[]>, 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.
RegisterTemporalArrayOutput<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.
RegisterTemporalArrayOutput<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.
RegisterTemporalArrayOutput<TKey,TPayload,TResult>(QueryContainer, IStreamable<PartitionKey<TKey>,TPayload>, Func<TResult[]>, 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.
RegisterTemporalArrayOutput<TKey,TPayload,TResult>(QueryContainer, IStreamable<PartitionKey<TKey>,TPayload>, Func<TResult[]>, 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.
RegisterTemporalArrayOutput<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.
RegisterTemporalArrayOutput<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.
RegisterTemporalInput<TPayload>(QueryContainer, IObservable<TPayload>, Expression<Func<TPayload,Int64>>, OnCompletedPolicy, DisorderPolicy, PeriodicPunctuationPolicy, String)	Converts a sequence of data elements to an IStreamable, start-edge only. 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.
RegisterTemporalInput<TPayload>(QueryContainer, IObservable<TPayload>, Expression<Func<TPayload,Int64>>, OnCompletedPolicy, PeriodicPunctuationPolicy, String)	Converts a sequence of data elements to an IStreamable, start-edge only. 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.
RegisterTemporalInput<TPayload>(QueryContainer, IObservable<TPayload>, Expression<Func<TPayload,Int64>>, Expression<Func<TPayload,Int64>>, OnCompletedPolicy, DisorderPolicy, PeriodicPunctuationPolicy, String)	Converts a sequence of data elements to an IStreamable, intervals and start-edges only. 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.
RegisterTemporalInput<TPayload>(QueryContainer, IObservable<TPayload>, Expression<Func<TPayload,Int64>>, Expression<Func<TPayload,Int64>>, OnCompletedPolicy, PeriodicPunctuationPolicy, String)	Converts a sequence of data elements to an IStreamable, intervals and start-edges only. 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.
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<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<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.

Applies to