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