Microsoft.StreamProcessing Namespace

Classes

Afa

Extension methods for creating an AFA object

Afa<TInput,TRegister>

A simpler form of AFA whose accumulator is a simple boolean indicating that the pattern has matched

Afa<TInput,TRegister,TAccumulator>

Class that describes an AFA completely, along with its properties.

AfaPlanNode

A node in the query plan representing function application to all input rows.

AlterLifetimePlanNode

A node in the query plan representing an alteration to the event lifetimes to a variable duration in the active, running query.

ARegex

Builder class for creating patterns against which to match stream data using a regular expression interface

BeatPlanNode

A node in the query plan representing breaking up each event timeline into equal intervals.

ClipByConstantPlanNode

A node in the query plan representing a lifetime truncation ("ClipByConstant") operation in the active, running query.

ColumnToRowPlanNode

A node in the query plan representing a shift from column-oriented data to row-oriented in the active, running query.

Config

Static class that holds all user configuration settings.

DisorderPolicy

Specifies how to handle out-of-order events

EgressPlanNode

A node in the query plan representing a data source in the active, running query.

EndEdgeFreeOutputPlanNode

A node in the query plan representing function application to all input rows.

EqualityComparerExpression<T>

Provides an implementation for wrapping two functions into an IEqualityComparerExpression<T>.

EvolvingStateEnumerable<TPayload>

An enumerable object whose contents are subject to changes as additional data becomes available from a stream.

ExtendLifetimePlanNode

A node in the query plan representing a lifetime extension ("ExtendLifetime") operation in the active, running query.

FilteredWindow<TKey,TSource>

Derived class from Window where additional semantics are applied when a filter is present

FusedPlanNode

A node in the query plan representing a data source in the active, running query.

GroupedWindowPlanNode<TInput,TState,TResult>

A node in the query plan representing a grouped window snapshot operation.

GroupPlanNode

Represents a grouping operation in a Map-Reduce process.

IngressException

Exception specific to an error occurring during data ingress.

IngressPlanNode

A node in the query plan representing a data source in the active, running query.

JoinPlanNode

A node in the query plan representing a join operation in the active, running query.

MulticastPlanNode

Represents an operation in a stream to allow multiple subscribers to receive the same messages.

OnCompletedPolicy

Specifies how to handle query completion (on receiving an OnCompleted call).

OutOfOrderPartitionedStreamEvent

Static class containing generator methods for OutOfOrderPartitionedStreamEvent objects.

OutOfOrderStreamEvent

Static class containing generator methods for OutOfOrderStreamEvent objects.

PartitionedDisorderPolicy

Specifies how to handle out-of-order events

PartitionedPeriodicPunctuationPolicy

Specifies how to inject punctuations into the resulting stream. Since punctuations force output, this exposes a throughput/latency tradeoff.

PartitionedStreamEvent

Partitioned stream event helpers that do not depend on generic arguments.

PeriodicPunctuationPolicy

Specifies how to inject punctuations into the resulting stream. Since punctuations force output, this exposes a throughput/latency tradeoff.

PlanNode

A node in the query plan representing the objects in the active, running query.

PointAtEndPlanNode

A node in the query plan representing a lifetime transformation moving the lifetime to a unit interval ("PointAtEnd") operation in the active, running query.

Process

A class representing a running query that can be checkpointed.

Properties

Streamable extension methods.

QuantizeLifetimePlanNode

A node in the query plan representing a lifetime transformation quantizing the start and end times along hopping boundaries in the active, running query.

QueryContainer

A container object that represents a stream query.

ReshapingPolicy

Policy that specifies whether and how events are reshaped at egress

RowToColumnPlanNode

A node in the query plan representing a shift from row-oriented data to column-oriented in the active, running query.

SelectBatchPlanNode

A node in the query plan representing function application to all input rows.

SelectManyPlanNode

A node in the query plan representing a SelectMany operation in the active, running query.

SelectPlanNode

A node in the query plan representing function application to all input rows.

SessionWindowPlanNode

A node in the query plan representing a session window truncation ("SessionTimeoutWindow") operation in the active, running query.

SnapshotWindowPlanNode<TInput,TState,TResult>

A node in the query plan representing a batched window snapshot operation.

SprayPlanNode

Represents an operation in a Map-Reduce job that sprays data to different nodes.

StitchPlanNode

A node in the query plan representing a unification of like events with adjacent lifetime intervals.

Streamable

Streamable extension methods.

StreamCache<TKey,TPayload>
       Stores a complete stream in a highly efficient, Trill friendly manner for subsequent iteration over  
       the data.
StreamEvent

Stream event helpers that do not depend on generic arguments.

StreamProcessingException

Represents a user exception somewhere within the

StreamProperties<TKey,TPayload>

Class that holds the set of stream properties for the stream

StreamScheduler

Class to set scheduling strategy for Trill (via Microsoft.StreamProcessing.Config.StreamScheduler)

TemporalSortPlanNode

A node in the query plan representing a temporal sorting (on timestamps) operation in the active, running query.

TimelinePolicy

Specifies how to assign a monotonically increasing temporal component to intrinsically atemporal data.

UngroupPlanNode

Represents an ungrouping operation in a Map-Reduce process.

UnionPlanNode

Indicates that the current node is a union operation.

UserDefinedPlanNode<TKey,TSource,TResult>

A node in the query plan representing an operation defined outside the library.

WherePlanNode

A node in the query plan representing a filtration ("where") operation in the active, running query.

Window<TKey,TSource>

Class representing a window within an aggregation operation.

Structs

Empty

A type representing the empty struct, similar to Unit in other libraries and languages.

OutOfOrderPartitionedStreamEvent<TKey,TPayload>

A structure for representing when a tuple had to be adjusted or dropped from a source of data ingress.

OutOfOrderStreamEvent<TPayload>

A structure for representing when a tuple had to be adjusted or dropped from a source of data ingress.

PartitionedStreamEvent<TKey,TPayload>

Represents a partitioned Stream event

StreamEvent<TPayload>

Represents an unpartitioned Stream event

Interfaces

IAbstractPattern<TKey,TPayload,TRegister,TAccumulator>

Interface is only public to serve CLR strong typing - instances should only be created internally. Do not use directly.

IAbstractPatternRoot<TKey,TPayload,TRegister,TAccumulator>

Interface is only public to serve CLR strong typing - instances should only be created internally. Do not use directly.

IComparerExpression<T>

A wrapper interface for an expression to compare two values of the given type.

IConnectableStreamable<TKey,TPayload>

Interface for dynamically connecting new streamable outputs to an existing stream

IEqualityComparerExpression<T>

An interface that provides an expression-based way to specify the same thing that IComparer<T> does: a function for equality and a function for computing a hash.

IIngressStreamable<TKey,TPayload>

An interface corresponding to a streamable at an ingress point to a query.

IMapDefinition<TMapInputLeft,TMapInputRight,TInnerKey,TReduceInput>

Placeholder interface for an operation that represents a map-reduce function

IMapDefinition<TOuterKey,TMapInputLeft,TMapInputRight,TInnerKey,TReduceInput>

Placeholder interface for an operation that represents a map-reduce function

IObservableIngressStreamable<TPayload>

An interface corresponding to a streamable at an ingress point to a query where input may be out of order.

IPartitionedIngressStreamable<TPartitionKey,TPayload>

An interface corresponding to a streamable at an ingress point to a query where input may be out of order.

IPassiveIngressStreamable<TKey,TPayload>

Interface for a passive ingress site that can be externally triggered to read available data.

IPattern<TKey,TPayload,TRegister,TAccumulator>

Interface is only public to serve CLR strong typing - instances should only be created internally. Do not use directly.

IStreamable<TKey,TPayload>

Primary interface for streamable operations - users should not be creating new classes that implement this interface without direct communication with the development team

Enums

AggregatePipeType

An enumeration of the available state management algorithm types.

JoinKind

Describes the kind of join used in a particular join query plan node.

OperationalHint

Gives a hint as to what methods should be used for an operator

PlanNodeKind

The kind of plan node.

SortingTechnique

Choices for what technique should be used at data ingress for sorting any out-of-order data.

StreamEventKind

Event kinds for row-wise StreamEvents

StreamMessageKind

Stream message kinds for individual messages passing through a query