IPassiveIngressStreamable<TKey,TPayload> Interface

Reference

Definition

Namespace:: Microsoft.StreamProcessing

Assembly:: Microsoft.StreamProcessing.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.

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

public interface IPassiveIngressStreamable<TKey,TPayload> : Microsoft.StreamProcessing.IIngressStreamable<TKey,TPayload>, Microsoft.StreamProcessing.IStreamable<TKey,TPayload>

type IPassiveIngressStreamable<'Key, 'Payload> = interface
    interface IIngressStreamable<'Key, 'Payload>
    interface IStreamable<'Key, 'Payload>

Public Interface IPassiveIngressStreamable(Of TKey, TPayload)
Implements IIngressStreamable(Of TKey, TPayload), IStreamable(Of TKey, TPayload)

Type Parameters

TKey

TPayload

Implements: IIngressStreamable<TKey,TPayload> IStreamable<TKey,TPayload>

Properties

ErrorMessages	Returns any errors that were encountered during code generation. (Inherited from IStreamable<TKey,TPayload>)
IngressSiteIdentifier	An identifier that uniquely identifies the ingress site relative to a running query. (Inherited from IIngressStreamable<TKey,TPayload>)
Properties	Returns the current properties of the stream, such as whether the stream is a constant-duration stream. (Inherited from IStreamable<TKey,TPayload>)

Methods

Subscribe(IStreamObserver<TKey,TPayload>)	Immediately starts sending events from the stream to the observer. (Inherited from IStreamable<TKey,TPayload>)
Trigger()	Trigger the stream to read (pull) data and push to the downstream pipeline

Extension Methods

GetProperties<TKey,TPayload>(IStreamable<TKey,TPayload>, StreamProperties<TKey,TPayload>)	Sets the out parameter (properties) to the current properties of the stream
SetProperties<TKey,TPayload>(IStreamable<TKey,TPayload>, StreamProperties<TKey,TPayload>)	Sets the current stream properties to the provided argument (newProperties)
SetProperty<TKey,TPayload>(IStreamable<TKey,TPayload>)	Enter into a mode where you can set a property for the stream.
Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TOutput>(IStreamable<TKey,TInput>, Func<Window<TKey, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState4,TOutput4>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput>>)	Applies multiple aggregates to snapshot windows on the input stream.
Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TState5,TOutput5,TOutput>(IStreamable<TKey, TInput>, Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState5,TOutput5>>, Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5, TOutput>>)	Applies multiple aggregates to snapshot windows on the input stream.
Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TOutput>(IStreamable<TKey, TInput>, Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState6,TOutput6>>, Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5, TOutput6,TOutput>>)	Applies multiple aggregates to snapshot windows on the input stream.
Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TState7, TOutput7,TOutput>(IStreamable<TKey,TInput>, Func<Window<TKey, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState7,TOutput7>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput>>)	Applies multiple aggregates to snapshot windows on the input stream.
Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TState7, TOutput7,TState8,TOutput8,TOutput>(IStreamable<TKey,TInput>, Func<Window<TKey, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState8,TOutput8>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8, TOutput>>)	Applies multiple aggregates to snapshot windows on the input stream.
Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TState7, TOutput7,TState8,TOutput8,TState9,TOutput9,TOutput>(IStreamable<TKey, TInput>, Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState9,TOutput9>>, Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5, TOutput6,TOutput7,TOutput8,TOutput9,TOutput>>)	Applies multiple aggregates to snapshot windows on the input stream.
Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TState7, TOutput7,TState8,TOutput8,TState9,TOutput9,TState10,TOutput10, TOutput>(IStreamable<TKey,TInput>, Func<Window<TKey,TInput>,IAggregate<TInput, TState1,TOutput1>>, Func<Window<TKey,TInput>,IAggregate<TInput, TState2,TOutput2>>, Func<Window<TKey,TInput>,IAggregate<TInput, TState3,TOutput3>>, Func<Window<TKey,TInput>,IAggregate<TInput, TState4,TOutput4>>, Func<Window<TKey,TInput>,IAggregate<TInput, TState5,TOutput5>>, Func<Window<TKey,TInput>,IAggregate<TInput, TState6,TOutput6>>, Func<Window<TKey,TInput>,IAggregate<TInput, TState7,TOutput7>>, Func<Window<TKey,TInput>,IAggregate<TInput, TState8,TOutput8>>, Func<Window<TKey,TInput>,IAggregate<TInput, TState9,TOutput9>>, Func<Window<TKey,TInput>,IAggregate<TInput, TState10,TOutput10>>, Expression<Func<TOutput1,TOutput2,TOutput3, TOutput4,TOutput5,TOutput6,TOutput7,TOutput8,TOutput9,TOutput10, TOutput>>)	Applies multiple aggregates to snapshot windows on the input stream.
Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TState7, TOutput7,TState8,TOutput8,TState9,TOutput9,TState10,TOutput10, TState11,TOutput11,TOutput>(IStreamable<TKey,TInput>, Func<Window<TKey, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState11,TOutput11>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8, TOutput9,TOutput10,TOutput11,TOutput>>)	Applies multiple aggregates to snapshot windows on the input stream.
Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TState7, TOutput7,TState8,TOutput8,TState9,TOutput9,TState10,TOutput10, TState11,TOutput11,TState12,TOutput12,TOutput>(IStreamable<TKey, TInput>, Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState12,TOutput12>>, Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5, TOutput6,TOutput7,TOutput8,TOutput9,TOutput10,TOutput11,TOutput12, TOutput>>)	Applies multiple aggregates to snapshot windows on the input stream.
Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TState7, TOutput7,TState8,TOutput8,TState9,TOutput9,TState10,TOutput10, TState11,TOutput11,TState12,TOutput12,TState13,TOutput13,TOutput>(IStreamable<TKey, TInput>, Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState12,TOutput12>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState13,TOutput13>>, Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5, TOutput6,TOutput7,TOutput8,TOutput9,TOutput10,TOutput11,TOutput12, TOutput13,TOutput>>)	Applies multiple aggregates to snapshot windows on the input stream.
Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TState7, TOutput7,TState8,TOutput8,TState9,TOutput9,TState10,TOutput10, TState11,TOutput11,TState12,TOutput12,TState13,TOutput13,TState14, TOutput14,TOutput>(IStreamable<TKey,TInput>, Func<Window<TKey, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState12,TOutput12>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState13,TOutput13>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState14,TOutput14>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8, TOutput9,TOutput10,TOutput11,TOutput12,TOutput13,TOutput14,TOutput>>)	Applies multiple aggregates to snapshot windows on the input stream.
Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TState7, TOutput7,TState8,TOutput8,TState9,TOutput9,TState10,TOutput10, TState11,TOutput11,TState12,TOutput12,TState13,TOutput13,TState14, TOutput14,TState15,TOutput15,TOutput>(IStreamable<TKey,TInput>, Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState12,TOutput12>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState13,TOutput13>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState14,TOutput14>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState15,TOutput15>>, Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5, TOutput6,TOutput7,TOutput8,TOutput9,TOutput10,TOutput11,TOutput12, TOutput13,TOutput14,TOutput15,TOutput>>)	Applies multiple aggregates to snapshot windows on the input stream.
Aggregate<TKey,TInput,TState,TOutput>(IStreamable<TKey,TInput>, Func<Window<TKey,TInput>,IAggregate<TInput,TState,TOutput>>)	Applies an aggregate to snapshot windows on the input stream.
Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TOutput>(IStreamable<TKey, TInput>, Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>, Expression<Func<TOutput1,TOutput2,TOutput>>)	Applies multiple aggregates to snapshot windows on the input stream.
Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TOutput>(IStreamable<TKey,TInput>, Func<Window<TKey, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState3,TOutput3>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput>>)	Applies multiple aggregates to snapshot windows on the input stream.
AlterEventDuration<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64)	Changes the Ve of each event according to the duration provided
AlterEventDuration<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<Int64,Int64,Int64>>)	Changes the Ve of each event according to the durationSelector, which is a function of start and end times
AlterEventDuration<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<Int64,Int64>>)	Changes the Ve of each event according to the durationSelector, which is a function of start time
AlterEventLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<Int64,Int64>>, Int64)	Changes the Vs and Ve of each event.
AlterEventLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<Int64,Int64>>, Expression<Func<Int64,Int64,Int64>>)	Changes the Vs and Ve of each event according to the startTimeSelector, and the durationSelector, which is a function of start and end times
AlterEventLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<Int64,Int64>>, Expression<Func<Int64,Int64>>)	Changes the Vs and Ve of each event according to the startTimeSelector, and the durationSelector, which is a function of start time
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Byte>>)	Computes a time-sensitive average aggregate over bytes using "snapshot windows" (SI terminology). Note that the accumulator internally is a ulong datatype.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Decimal>>)	Computes a time-sensitive average aggregate over decimals using "snapshot windows" (SI terminology). Note that the accumulator internally is a decimal datatype.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Double>>)	Computes a time-sensitive average aggregate over doubles using "snapshot windows" (SI terminology). Note that the accumulator internally is a double datatype.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int16>>)	Computes a time-sensitive average aggregate over shorts using "snapshot windows" (SI terminology). Note that the accumulator internally is a long datatype.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int32>>)	Computes a time-sensitive average aggregate over ints using "snapshot windows" (SI terminology). Note that the accumulator internally is a long datatype.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int64>>)	Computes a time-sensitive average aggregate over longs using "snapshot windows" (SI terminology). Note that the accumulator internally is a long datatype.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Byte>>>)	Computes a time-sensitive average aggregate over nullable bytes using "snapshot windows" (SI terminology). Note that the accumulator internally is a ulong datatype and that nulls have no affect on the average.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Decimal>>>)	Computes a time-sensitive average aggregate over nullable decimals using "snapshot windows" (SI terminology). Note that the accumulator internally is a decimal datatype and that nulls have no affect on the average.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Double>>>)	Computes a time-sensitive average aggregate over nullable doubles using "snapshot windows" (SI terminology). Note that the accumulator internally is a double datatype and that nulls have no affect on the average.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int16>>>)	Computes a time-sensitive average aggregate over nullable shorts using "snapshot windows" (SI terminology). Note that the accumulator internally is a long datatype and that nulls have no affect on the average.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int32>>>)	Computes a time-sensitive average aggregate over nullable ints using "snapshot windows" (SI terminology). Note that the accumulator internally is a long datatype and that nulls have no affect on the average.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int64>>>)	Computes a time-sensitive average aggregate over nullable longs using "snapshot windows" (SI terminology). Note that the accumulator internally is a long datatype and that nulls have no affect on the average.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<BigInteger>>>)	Computes a time-sensitive average aggregate over nullable BigIntegers using "snapshot windows" (SI terminology). Note that the accumulator internally is a BigInteger datatype and that nulls have no affect on the average.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Complex>>>)	Computes a time-sensitive average aggregate over nullable Complexs using "snapshot windows" (SI terminology). Note that the accumulator internally is a Complex datatype and that nulls have no affect on the average.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<SByte>>>)	Computes a time-sensitive average aggregate over nullable sbytes using "snapshot windows" (SI terminology). Note that the accumulator internally is a long datatype and that nulls have no affect on the average.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Single>>>)	Computes a time-sensitive average aggregate over nullable floats using "snapshot windows" (SI terminology). Note that the accumulator internally is a float datatype and that nulls have no affect on the average.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt16>>>)	Computes a time-sensitive average aggregate over nullable ushorts using "snapshot windows" (SI terminology). Note that the accumulator internally is a ulong datatype and that nulls have no affect on the average.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt32>>>)	Computes a time-sensitive average aggregate over nullable uints using "snapshot windows" (SI terminology). Note that the accumulator internally is a ulong datatype and that nulls have no affect on the average.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt64>>>)	Computes a time-sensitive average aggregate over nullable ulongs using "snapshot windows" (SI terminology). Note that the accumulator internally is a ulong datatype and that nulls have no affect on the average.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,BigInteger>>)	Computes a time-sensitive average aggregate over BigIntegers using "snapshot windows" (SI terminology). Note that the accumulator internally is a BigInteger datatype.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Complex>>)	Computes a time-sensitive average aggregate over Complexs using "snapshot windows" (SI terminology). Note that the accumulator internally is a Complex datatype.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,SByte>>)	Computes a time-sensitive average aggregate over sbytes using "snapshot windows" (SI terminology). Note that the accumulator internally is a long datatype.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Single>>)	Computes a time-sensitive average aggregate over floats using "snapshot windows" (SI terminology). Note that the accumulator internally is a float datatype.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt16>>)	Computes a time-sensitive average aggregate over ushorts using "snapshot windows" (SI terminology). Note that the accumulator internally is a ulong datatype.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt32>>)	Computes a time-sensitive average aggregate over uints using "snapshot windows" (SI terminology). Note that the accumulator internally is a ulong datatype.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt64>>)	Computes a time-sensitive average aggregate over ulongs using "snapshot windows" (SI terminology). Note that the accumulator internally is a ulong datatype.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Byte>>)	Computes a time-sensitive average of squares aggregate over bytes using "snapshot windows" (SI terminology). Note that the accumulator internally is a ulong datatype.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Decimal>>)	Computes a time-sensitive average of squares aggregate over decimals using "snapshot windows" (SI terminology). Note that the accumulator internally is a decimal datatype.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Double>>)	Computes a time-sensitive average of squares aggregate over doubles using "snapshot windows" (SI terminology). Note that the accumulator internally is a double datatype.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int16>>)	Computes a time-sensitive average of squares aggregate over shorts using "snapshot windows" (SI terminology). Note that the accumulator internally is a long datatype.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int32>>)	Computes a time-sensitive average of squares aggregate over ints using "snapshot windows" (SI terminology). Note that the accumulator internally is a long datatype.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int64>>)	Computes a time-sensitive average of squares aggregate over longs using "snapshot windows" (SI terminology). Note that the accumulator internally is a long datatype.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Byte>>>)	Computes a time-sensitive average of squares aggregate over nullable bytes using "snapshot windows" (SI terminology). Note that the accumulator internally is a ulong datatype and that nulls have no affect on the average.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Decimal>>>)	Computes a time-sensitive average of squares aggregate over nullable decimals using "snapshot windows" (SI terminology). Note that the accumulator internally is a decimal datatype and that nulls have no affect on the average.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Double>>>)	Computes a time-sensitive average of squares aggregate over nullable doubles using "snapshot windows" (SI terminology). Note that the accumulator internally is a double datatype and that nulls have no affect on the average.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int16>>>)	Computes a time-sensitive average of squares aggregate over nullable shorts using "snapshot windows" (SI terminology). Note that the accumulator internally is a long datatype and that nulls have no affect on the average.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int32>>>)	Computes a time-sensitive average of squares aggregate over nullable ints using "snapshot windows" (SI terminology). Note that the accumulator internally is a long datatype and that nulls have no affect on the average.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int64>>>)	Computes a time-sensitive average of squares aggregate over nullable longs using "snapshot windows" (SI terminology). Note that the accumulator internally is a long datatype and that nulls have no affect on the average.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<BigInteger>>>)	Computes a time-sensitive average of squares aggregate over nullable BigIntegers using "snapshot windows" (SI terminology). Note that the accumulator internally is a BigInteger datatype and that nulls have no affect on the average.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Complex>>>)	Computes a time-sensitive average of squares aggregate over nullable Complexs using "snapshot windows" (SI terminology). Note that the accumulator internally is a Complex datatype and that nulls have no affect on the average.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<SByte>>>)	Computes a time-sensitive average of squares aggregate over nullable sbytes using "snapshot windows" (SI terminology). Note that the accumulator internally is a long datatype and that nulls have no affect on the average.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Single>>>)	Computes a time-sensitive average of squares aggregate over nullable floats using "snapshot windows" (SI terminology). Note that the accumulator internally is a float datatype and that nulls have no affect on the average.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt16>>>)	Computes a time-sensitive average of squares aggregate over nullable ushorts using "snapshot windows" (SI terminology). Note that the accumulator internally is a ulong datatype and that nulls have no affect on the average.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt32>>>)	Computes a time-sensitive average of squares aggregate over nullable uints using "snapshot windows" (SI terminology). Note that the accumulator internally is a ulong datatype and that nulls have no affect on the average.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt64>>>)	Computes a time-sensitive average of squares aggregate over nullable ulongs using "snapshot windows" (SI terminology). Note that the accumulator internally is a ulong datatype and that nulls have no affect on the average.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,BigInteger>>)	Computes a time-sensitive average of squares aggregate over BigIntegers using "snapshot windows" (SI terminology). Note that the accumulator internally is a BigInteger datatype.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Complex>>)	Computes a time-sensitive average of squares aggregate over Complexs using "snapshot windows" (SI terminology). Note that the accumulator internally is a Complex datatype.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,SByte>>)	Computes a time-sensitive average of squares aggregate over sbytes using "snapshot windows" (SI terminology). Note that the accumulator internally is a long datatype.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Single>>)	Computes a time-sensitive average of squares aggregate over floats using "snapshot windows" (SI terminology). Note that the accumulator internally is a float datatype.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt16>>)	Computes a time-sensitive average of squares aggregate over ushorts using "snapshot windows" (SI terminology). Note that the accumulator internally is a ulong datatype.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt32>>)	Computes a time-sensitive average of squares aggregate over uints using "snapshot windows" (SI terminology). Note that the accumulator internally is a ulong datatype.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt64>>)	Computes a time-sensitive average of squares aggregate over ulongs using "snapshot windows" (SI terminology). Note that the accumulator internally is a ulong datatype.
Cache<TKey,TPayload>(IStreamable<TKey,TPayload>, UInt64, Boolean, Boolean)	Caches the complete results computed by the streamable upon an immediate call to subscribe. This call will block until the underlying query has fully executed and the result cached.
Chop<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64, Int64)	Performs the 'Chop' operator to chop (partition) long-lasting intervals and edges across beat boundaries.
ClipEventDuration<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64)	Passes a truncated version of each event, where the event is truncated by a maximum event length.
ClipEventDuration<TKey,TPayload,TClip>(IStreamable<TKey,TPayload>, IStreamable<TKey,TClip>)	Passes a truncated version of each event on the left, where the left event is truncated by the first event on the right whose Vs occurs after the event on the left. There is no restriction on join condition.
ClipEventDuration<TKey,TLeft,TRight,TJoinKey>(IStreamable<TKey, TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight,TJoinKey>>)	Passes a truncated version of each event on the left, where the left event is truncated by the first event on the right whose Vs occurs after the event on the left, whose join condition is met, and where the keys for both streams match. A fast join key comparer is passed in for efficiency.
ConsecutivePairs<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,TPayload,TResult>>)	Finds patterns of events that are repeated consecutively
Count<TKey,TPayload>(IStreamable<TKey,TPayload>)	Computes a time-sensitive count aggregate using "snapshot windows" (SI terminology).
CountNotNull<TKey,TPayload,TValue>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,TValue>>)	Computes a time-sensitive count aggregate of the non-null values using "snapshot windows" (SI terminology).
DefinePattern<TKey,TPayload>(IStreamable<TKey,TPayload>)	Define a pattern against which data in the input stream may be matched
DefinePattern<TKey,TPayload,TRegister,TAccumulator>(IStreamable<TKey,TPayload>, TRegister, TAccumulator)	Define a pattern against which data in the input stream may be matched
Detect<TKey,TPayload>(IStreamable<TKey,TPayload>, Func<IAbstractPatternRoot<TKey, TPayload,Empty,Boolean>,IPattern<TKey,TPayload,Empty,Boolean>>, Int64, Boolean, Boolean)	Detect a pattern over the incoming stream. Takes augmented regular expression as input. Create AFA using the Regex.* API or direct AFA specification.
Detect<TKey,TPayload,TRegister>(IStreamable<TKey,TPayload>, TRegister, Func<IAbstractPatternRoot<TKey,TPayload,TRegister,Boolean>,IPattern<TKey, TPayload,TRegister,Boolean>>, Int64, Boolean, Boolean)	Detect a pattern over the incoming stream. Takes augmented regular expression as input. Create AFA using the Regex.* API or direct AFA specification.
Detect<TKey,TPayload,TRegister,TAccumulator>(IStreamable<TKey, TPayload>, TRegister, TAccumulator, Func<IAbstractPatternRoot<TKey, TPayload,TRegister,TAccumulator>,IPattern<TKey,TPayload,TRegister, TAccumulator>>, Int64, Boolean, Boolean)	Detect a pattern over the incoming stream. Takes augmented regular expression as input. Create AFA using the Regex.* API or direct AFA specification.
Detect<TKey,TPayload,TRegister,TAccumulator>(IStreamable<TKey,TPayload>, Afa<TPayload,TRegister,TAccumulator>, Int64, Boolean, Boolean)	Detect a pattern over the incoming stream. Takes augmented finite automaton (AFA) as input. Create AFA using the Regex.* API or direct AFA specification.
Distinct<TKey,TPayload>(IStreamable<TKey,TPayload>)	Filter out any duplicate entries at each snapshot
Distinct<TKey,TInput,TResult>(IStreamable<TKey,TInput>, Expression<Func<TInput,TResult>>)	Removes partial duplicates per timestamp. If two events match by the given expression and their timestamps, they are considered duplicates.
ExtendLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64)	Create a stream that extends all event lifetimes by a fixed amount.
FollowedByImmediate<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Boolean>>, Expression<Func<TPayload, Boolean>>, Expression<Func<TPayload,TPayload,TResult>>, Int64)	Finds patterns of A followed immediately by B (with no other intermediate events), occurring within (strictly less than) a given time duration
FollowedByImmediate<TKey,TPayload,TPayload2,TResult>(IStreamable<TKey, TPayload>, IStreamable<TKey,TPayload2>, Expression<Func<TPayload, Boolean>>, Expression<Func<TPayload2,Boolean>>, Expression<Func<TPayload, TPayload2,TResult>>, Int64)	Finds patterns of A on the left followed immediately by B on the right (with no other intermediate events), occurring within (strictly less than) a given time duration
GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TOutput>(IStreamable<TOuterKey,TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput>>)	Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.
GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TOutput>(IStreamable<TOuterKey, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput>>)	Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.
GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TOutput>(IStreamable<TOuterKey, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput>>)	Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.
GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TOutput>(IStreamable<TOuterKey,TInput>, Expression<Func<TInput, TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey,TInnerKey>, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput>>)	Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.
GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TOutput>(IStreamable<TOuterKey,TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput>>)	Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.
GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TState8,TOutput8,TOutput>(IStreamable<TOuterKey, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput8,TOutput>>)	Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.
GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TOutput>(IStreamable<TOuterKey, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput8,TOutput9,TOutput>>)	Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.
GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10, TOutput10,TOutput>(IStreamable<TOuterKey,TInput>, Expression<Func<TInput, TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey,TInnerKey>, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput8,TOutput9,TOutput10,TOutput>>)	Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.
GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10, TOutput10,TState11,TOutput11,TOutput>(IStreamable<TOuterKey,TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput8,TOutput9,TOutput10,TOutput11,TOutput>>)	Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.
GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10, TOutput10,TState11,TOutput11,TState12,TOutput12,TOutput>(IStreamable<TOuterKey, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState12,TOutput12>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput8,TOutput9,TOutput10,TOutput11,TOutput12,TOutput>>)	Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.
GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10, TOutput10,TState11,TOutput11,TState12,TOutput12,TState13,TOutput13, TOutput>(IStreamable<TOuterKey,TInput>, Expression<Func<TInput, TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey,TInnerKey>, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState12,TOutput12>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState13,TOutput13>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput8,TOutput9,TOutput10,TOutput11,TOutput12,TOutput13,TOutput>>)	Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.
GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10, TOutput10,TState11,TOutput11,TState12,TOutput12,TState13,TOutput13, TState14,TOutput14,TOutput>(IStreamable<TOuterKey,TInput>, Expression<Func<TInput, TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey,TInnerKey>, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState12,TOutput12>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState13,TOutput13>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState14,TOutput14>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput8,TOutput9,TOutput10,TOutput11,TOutput12,TOutput13,TOutput14, TOutput>>)	Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.
GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10, TOutput10,TState11,TOutput11,TState12,TOutput12,TState13,TOutput13, TState14,TOutput14,TState15,TOutput15,TOutput>(IStreamable<TOuterKey, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState12,TOutput12>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState13,TOutput13>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState14,TOutput14>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState15,TOutput15>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput8,TOutput9,TOutput10,TOutput11,TOutput12,TOutput13,TOutput14, TOutput15,TOutput>>)	Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.
GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TOutput>(IStreamable<TOuterKey, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput>>)	Groups input events by a key selector and applies an aggregate to "snapshot windows" (SI terminology) on each group.
GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TOutput>(IStreamable<TOuterKey,TInput>, Expression<Func<TInput, TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey,TInnerKey>, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput>>)	Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.
GroupApply<TOuterKey,TPayload,TInnerKey,TResult>(IStreamable<TOuterKey, TPayload>, Expression<Func<TPayload,TInnerKey>>, Func<IStreamable<CompoundGroupKey<TOuterKey, TInnerKey>,TPayload>,IStreamable<CompoundGroupKey<TOuterKey,TInnerKey>, TResult>>)	Performs a group and apply operation on the stream.
GroupApply<TOuterKey,TPayload,TInnerKey,TBind,TResult>(IStreamable<TOuterKey, TPayload>, Expression<Func<TPayload,TInnerKey>>, Func<IStreamable<CompoundGroupKey<TOuterKey, TInnerKey>,TPayload>,IStreamable<CompoundGroupKey<TOuterKey,TInnerKey>, TBind>>, Expression<Func<GroupSelectorInput<TInnerKey>,TBind, TResult>>)	Performs a group and apply operation on the stream.
GroupBy<TOuterKey,TPayload,TInnerKey>(IStreamable<TOuterKey,TPayload>, Expression<Func<TPayload,TInnerKey>>)	Needed to make the comprehension syntax happy. Consider using GroupApply instead.
HoppingWindowLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64, Int64, Int64)	Adjusts the lifetime of incoming events to implement, when used in combination with aggregates, hopping windows. In this implementation each incoming event results in a single outgoing event, which means that subsequent aggregates only produce output when the input changes. For instance, if a single point event is received and the windowSize, period, and offset are 100, 2, and 0 respectively, a single aggregate output is produced with a lifetime of 100 ticks.
Join<TKey,TLeft,TRight,TResult>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TRight,TResult>>)	Performs a cross-product between 2 streams
Join<TKey,TLeft,TRight,TResult>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TRight,TResult>>, Int64)	Performs a cross-product between 2 streams
Join<TKey,TLeft,TRight,TJoinKey,TResult>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight, TJoinKey>>, Expression<Func<TLeft,TRight,TResult>>)	Performs an equijoin between 2 streams where the join key is of type TJoinKey and selectors are passed to extract join keys from payloads
Join<TKey,TLeft,TRight,TJoinKey,TResult>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight, TJoinKey>>, Expression<Func<TLeft,TRight,TResult>>, OperationalHint)	Performs an equijoin between 2 streams where the join key is of type TJoinKey and selectors are passed to extract join keys from payloads
Join<TKey,TLeft,TRight,TJoinKey,TResult>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight, TJoinKey>>, Expression<Func<TLeft,TRight,TResult>>, Int64, OperationalHint)	Performs an equijoin between 2 streams where the join key is of type TJoinKey and selectors are passed to extract join keys from payloads
LeftOuterJoin<TKey,TLeft,TRight,TJoinKey,TResult>(IStreamable<TKey, TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight,TJoinKey>>, Expression<Func<TLeft,TRight, Boolean>>, Expression<Func<TLeft,TResult>>, Expression<Func<TLeft, TRight,TResult>>)
LeftOuterJoin<TKey,TLeft,TRight,TJoinKey,TResult>(IStreamable<TKey, TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight,TJoinKey>>, Expression<Func<TLeft,TResult>>, Expression<Func<TLeft,TRight,TResult>>)	Macro to perform a left-outer-join operation.
LeftOuterJoin<TKey,TLeft,TRight,TJoinKey,TResult>(IStreamable<TKey, TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight,TJoinKey>>, Expression<Func<TLeft,TResult>>, Expression<Func<TLeft,TRight,TResult>>, Int64)	Macro to perform a left-outer-join operation.
Map<TOuterKey,TMapInput,TReduceInput>(IStreamable<TOuterKey,TMapInput>, Func<IStreamable<TOuterKey,TMapInput>,IStreamable<TOuterKey,TReduceInput>>)	The Map phase of a single input map-only operation. Allows the specification of streaming logic on the mapper.
Map<TOuterKey,TMapInput,TInnerKey,TReduceInput>(IStreamable<TOuterKey, TMapInput>, Func<IStreamable<TOuterKey,TMapInput>,IStreamable<TOuterKey, TReduceInput>>, Expression<Func<TReduceInput,TInnerKey>>)	The Map phase of a single input map/reduce operation. Allows the specification of streaming logic on the mapper, and a key selector for the next (reduce) stage.
Max<TKey,TPayload>(IStreamable<TKey,TPayload>)	Computes a time-sensitive maximum aggregate using "snapshot windows" (SI terminology).
Max<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Comparison<TPayload>>)	Computes a time-sensitive maximum aggregate using "snapshot windows" (SI terminology).
Max<TKey,TPayload,T>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,T>>)	Computes a time-sensitive maximum aggregate using "snapshot windows" (SI terminology).
Max<TKey,TPayload,T>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,T>>, Expression<Comparison<T>>)	Computes a time-sensitive maximum aggregate using "snapshot windows" (SI terminology) with the provided ordering comparer.
Min<TKey,TPayload>(IStreamable<TKey,TPayload>)	Computes a time-sensitive minimum aggregate using "snapshot windows" (SI terminology).
Min<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Comparison<TPayload>>)	Computes a time-sensitive minimum aggregate using "snapshot windows" (SI terminology).
Min<TKey,TPayload,T>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,T>>)	Computes a time-sensitive minimum aggregate using "snapshot windows" (SI terminology).
Min<TKey,TPayload,T>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,T>>, Expression<Comparison<T>>)	Computes a time-sensitive minimum aggregate using "snapshot windows" (SI terminology) with the provided ordering comparer.
Multicast<TKey,TPayload>(IStreamable<TKey,TPayload>, Int32)	Performs multicast over a streamable. This allows query writers to execute multiple subqueries over the same physical input stream.
Multicast<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Func<IStreamable<TKey,TPayload>,IStreamable<TKey,TResult>>)	Performs multicast over a streamable. This allows query writers to execute multiple subqueries over the same physical input stream.
Multicast<TKey,TPayloadLeft,TPayloadRight,TResult>(IStreamable<TKey, TPayloadLeft>, IStreamable<TKey,TPayloadRight>, Func<IStreamable<TKey, TPayloadLeft>,IStreamable<TKey,TPayloadRight>,IStreamable<TKey, TResult>>)	Performs multicast over a streamable. This allows query writers to execute multiple subqueries over the same physical input stream.
Pivot<TKey,TInput,TOutput,TGroupKey,TValue,TAggValue,TState>(IStreamable<TKey, TInput>, Expression<Func<TOutput>>, Expression<Func<TInput,TGroupKey>>, Expression<Func<TInput,String>>, Expression<Func<TInput,TValue>>, Func<Window<CompoundGroupKey<TKey,TGroupKey>,TValue>,IAggregate<TValue, TState,TAggValue>>)
PointAtEnd<TKey,TPayload>(IStreamable<TKey,TPayload>)	Create a stream that reports all deaccumulations as an insert-only point stream (converts all events into point events at end).
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Byte>>)	Computes a time-sensitive product aggregate over bytes using "snapshot windows" (SI terminology).
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Decimal>>)	Computes a time-sensitive product aggregate over decimals using "snapshot windows" (SI terminology).
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Double>>)	Computes a time-sensitive product aggregate over doubles using "snapshot windows" (SI terminology).
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int16>>)	Computes a time-sensitive product aggregate over shorts using "snapshot windows" (SI terminology).
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int32>>)	Computes a time-sensitive product aggregate over ints using "snapshot windows" (SI terminology).
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int64>>)	Computes a time-sensitive product aggregate over longs using "snapshot windows" (SI terminology).
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Byte>>>)	Computes a time-sensitive product aggregate over nullable bytes using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Decimal>>>)	Computes a time-sensitive product aggregate over nullable decimals using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Double>>>)	Computes a time-sensitive product aggregate over nullable doubles using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int16>>>)	Computes a time-sensitive product aggregate over nullable shorts using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int32>>>)	Computes a time-sensitive product aggregate over nullable ints using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int64>>>)	Computes a time-sensitive product aggregate over nullable longs using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<BigInteger>>>)	Computes a time-sensitive product aggregate over nullable BigIntegers using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Complex>>>)	Computes a time-sensitive product aggregate over nullable Complexs using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<SByte>>>)	Computes a time-sensitive product aggregate over nullable sbytes using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Single>>>)	Computes a time-sensitive product aggregate over nullable floats using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt16>>>)	Computes a time-sensitive product aggregate over nullable ushorts using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt32>>>)	Computes a time-sensitive product aggregate over nullable uints using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt64>>>)	Computes a time-sensitive product aggregate over nullable ulongs using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,BigInteger>>)	Computes a time-sensitive product aggregate over BigIntegers using "snapshot windows" (SI terminology).
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Complex>>)	Computes a time-sensitive product aggregate over Complexs using "snapshot windows" (SI terminology).
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,SByte>>)	Computes a time-sensitive product aggregate over sbytes using "snapshot windows" (SI terminology).
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Single>>)	Computes a time-sensitive product aggregate over floats using "snapshot windows" (SI terminology).
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt16>>)	Computes a time-sensitive product aggregate over ushorts using "snapshot windows" (SI terminology).
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt32>>)	Computes a time-sensitive product aggregate over uints using "snapshot windows" (SI terminology).
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt64>>)	Computes a time-sensitive product aggregate over ulongs using "snapshot windows" (SI terminology).
Publish<TKey,TPayload>(IStreamable<TKey,TPayload>)	Performs dynamic version of multicast over a streamable. This allows query writers to execute multiple subqueries over the same physical input stream - streams can be added or removed. It is up to the user to ensure that the stream has no end edges, otherwise a dynamically subscribed subscriber may receive a malformed stream (end edge without corresponding start edge). Usage: stream.Publish(); stream.Subscribe(...); stream.Connect(); stream.Subscribe(...);
QuantizeLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64, Int64, Int64)	Adjusts the lifetime of incoming events to snap the start and end time of each event to quantized boundaries. The function is similar to a hopping lifetime expression, except that all start edges are either moved earlier or stay the same, and all end edges either move later or stay the same.
RepetitiveHoppingWindowLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64, Int64, Int64)	Adjusts the lifetime of incoming events to implement, when used in combination with aggregates, repetitive hopping windows. In this implementation each incoming event results in an arbitrary number of outgoing events. For instance, if a single point event is received and the windowSize, period, and offset are 100, 2, and 0 respectively, 50 identical aggregate outputs are produced, each with a lifetime of 2 ticks.
Select<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,TResult>>)	Performs a project over a streamable.
Select<TKey,TOld,TNew>(IStreamable<TKey,TOld>, Expression<Func<TNew>>, IDictionary<String,Expression<Func<TOld,Object>>>)
Select<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<Int64,TPayload,TResult>>)	Performs a project over a streamable.
Select<TKey,TOld,TNew,TField1>(IStreamable<TKey,TOld>, Expression<Func<TNew>>, Expression<Func<TNew,TField1>>, Expression<Func<TOld,TField1>>)
Select<TKey,TOld,TNew,TField1,TField2>(IStreamable<TKey,TOld>, Expression<Func<TNew>>, Expression<Func<TNew,TField1>>, Expression<Func<TOld, TField1>>, Expression<Func<TNew,TField2>>, Expression<Func<TOld, TField2>>)
SelectBatch<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Action<TPayload[],TResult[]>>)	Performs a transformation over a streamable, grouping payloads into a batch to transform, and providing an output batch to populate. NOTE: The intended semantics of this method is equivalent to Select over individual rows. It is up to the caller of this method to ensure those semantics.
SelectByKey<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<TKey,TPayload,TResult>>)	Performs a project over a streamable, relative to the grouping key.
SelectByKey<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<Int64,TKey,TPayload,TResult>>)	Performs a project over a streamable, relative to the grouping key.
SelectMany<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,IEnumerable<TResult>>>)	This select many is used for generating many payloads out of one
SelectMany<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<Int64,TPayload,IEnumerable<TResult>>>)	This select many is used for generating many payloads out of one
SelectMany<TKey,TLeft,TRight,TResult>(IStreamable<TKey,TLeft>, Func<Empty,IStreamable<TKey,TRight>>, Expression<Func<TLeft,TRight,TResult>>)	This select many is used for joins derived from the comprehension syntax as well as non-empty reducers in Group and Apply
SelectManyByKey<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<TKey,TPayload,IEnumerable<TResult>>>)	This select many is used for generating many payloads out of one
SelectManyByKey<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<Int64,TKey,TPayload,IEnumerable<TResult>>>)	This select many is used for generating many payloads out of one
Sessionize<TKey,TPayload,TSessionKey,TResult>(IStreamable<TKey, TPayload>, Expression<Func<TPayload,Boolean>>, Expression<Func<TPayload, Boolean>>, Expression<Func<TPayload,TSessionKey>>, Expression<Func<TPayload, TPayload,TResult>>)	Convert a stream of start and end sessions to a single per-session stream, where we care about the data in the end session. Sessions are output as point events at the timestamp of the end session.
SessionTimeoutWindow<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64, Int64)	The window type implements sessions with timeout in Trill. The current window is extended as long as new events arrive within a specified timeout period. Once a timeout period elapses with no data (for a given grouping key), the window is closed.
ShiftEventLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64)	Shifts the lifetime by the specified amount of time
ShiftEventLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<Int64,Int64>>)	Shifts the lifetime by the shiftSelector, which is a function of the event start time
Stitch<TKey,TPayload>(IStreamable<TKey,TPayload>)	Stitch is the reverse of the 'Chop' operator: when it finds an END payload and a BEGIN payload at the same time, it removes both from the stream. The net effect is that if a value in a signal doesn't change, then the stream won't have new events. This is mostly useful for human eyes; mathemtically, the two should be identical
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Byte>>)	Computes a time-sensitive sum aggregate over bytes using "snapshot windows" (SI terminology).
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Decimal>>)	Computes a time-sensitive sum aggregate over decimals using "snapshot windows" (SI terminology).
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Double>>)	Computes a time-sensitive sum aggregate over doubles using "snapshot windows" (SI terminology).
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int16>>)	Computes a time-sensitive sum aggregate over shorts using "snapshot windows" (SI terminology).
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int32>>)	Computes a time-sensitive sum aggregate over ints using "snapshot windows" (SI terminology).
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int64>>)	Computes a time-sensitive sum aggregate over longs using "snapshot windows" (SI terminology).
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Byte>>>)	Computes a time-sensitive sum aggregate over nullable bytes using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Decimal>>>)	Computes a time-sensitive sum aggregate over nullable decimals using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Double>>>)	Computes a time-sensitive sum aggregate over nullable doubles using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int16>>>)	Computes a time-sensitive sum aggregate over nullable shorts using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int32>>>)	Computes a time-sensitive sum aggregate over nullable ints using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int64>>>)	Computes a time-sensitive sum aggregate over nullable longs using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<BigInteger>>>)	Computes a time-sensitive sum aggregate over nullable BigIntegers using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Complex>>>)	Computes a time-sensitive sum aggregate over nullable Complexs using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<SByte>>>)	Computes a time-sensitive sum aggregate over nullable sbytes using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Single>>>)	Computes a time-sensitive sum aggregate over nullable floats using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt16>>>)	Computes a time-sensitive sum aggregate over nullable ushorts using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt32>>>)	Computes a time-sensitive sum aggregate over nullable uints using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt64>>>)	Computes a time-sensitive sum aggregate over nullable ulongs using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,BigInteger>>)	Computes a time-sensitive sum aggregate over BigIntegers using "snapshot windows" (SI terminology).
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Complex>>)	Computes a time-sensitive sum aggregate over Complexs using "snapshot windows" (SI terminology).
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,SByte>>)	Computes a time-sensitive sum aggregate over sbytes using "snapshot windows" (SI terminology).
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Single>>)	Computes a time-sensitive sum aggregate over floats using "snapshot windows" (SI terminology).
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt16>>)	Computes a time-sensitive sum aggregate over ushorts using "snapshot windows" (SI terminology).
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt32>>)	Computes a time-sensitive sum aggregate over uints using "snapshot windows" (SI terminology).
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt64>>)	Computes a time-sensitive sum aggregate over ulongs using "snapshot windows" (SI terminology).
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Byte>>)	Computes a time-sensitive sum of squares aggregate over bytes using "snapshot windows" (SI terminology).
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Decimal>>)	Computes a time-sensitive sum of squares aggregate over decimals using "snapshot windows" (SI terminology).
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Double>>)	Computes a time-sensitive sum of squares aggregate over doubles using "snapshot windows" (SI terminology).
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int16>>)	Computes a time-sensitive sum of squares aggregate over shorts using "snapshot windows" (SI terminology).
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int32>>)	Computes a time-sensitive sum of squares aggregate over ints using "snapshot windows" (SI terminology).
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int64>>)	Computes a time-sensitive sum of squares aggregate over longs using "snapshot windows" (SI terminology).
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Byte>>>)	Computes a time-sensitive sum of squares aggregate over nullable bytes using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Decimal>>>)	Computes a time-sensitive sum of squares aggregate over nullable decimals using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Double>>>)	Computes a time-sensitive sum of squares aggregate over nullable doubles using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int16>>>)	Computes a time-sensitive sum of squares aggregate over nullable shorts using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int32>>>)	Computes a time-sensitive sum of squares aggregate over nullable ints using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int64>>>)	Computes a time-sensitive sum of squares aggregate over nullable longs using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<BigInteger>>>)	Computes a time-sensitive sum of squares aggregate over nullable BigIntegers using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Complex>>>)	Computes a time-sensitive sum of squares aggregate over nullable Complexs using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<SByte>>>)	Computes a time-sensitive sum of squares aggregate over nullable sbytes using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Single>>>)	Computes a time-sensitive sum of squares aggregate over nullable floats using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt16>>>)	Computes a time-sensitive sum of squares aggregate over nullable ushorts using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt32>>>)	Computes a time-sensitive sum of squares aggregate over nullable uints using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt64>>>)	Computes a time-sensitive sum of squares aggregate over nullable ulongs using "snapshot windows" (SI terminology). Note that nulls have no affect on the sum.
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,BigInteger>>)	Computes a time-sensitive sum of squares aggregate over BigIntegers using "snapshot windows" (SI terminology).
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Complex>>)	Computes a time-sensitive sum of squares aggregate over Complexs using "snapshot windows" (SI terminology).
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,SByte>>)	Computes a time-sensitive sum of squares aggregate over sbytes using "snapshot windows" (SI terminology).
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Single>>)	Computes a time-sensitive sum of squares aggregate over floats using "snapshot windows" (SI terminology).
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt16>>)	Computes a time-sensitive sum of squares aggregate over ushorts using "snapshot windows" (SI terminology).
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt32>>)	Computes a time-sensitive sum of squares aggregate over uints using "snapshot windows" (SI terminology).
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt64>>)	Computes a time-sensitive sum of squares aggregate over ulongs using "snapshot windows" (SI terminology).
ToBinaryStream<TKey,TPayload>(IStreamable<TKey,TPayload>, Stream, Boolean)	Serialize streamable into a binary stream
ToBinaryStream<TKey,TPayload>(IStreamable<TKey,TPayload>, String)	Serialize streamble into a binary file
TopK<TKey,TPayload>(IStreamable<TKey,TPayload>, Int32)	Computes a time-sensitive top-k aggregate using "snapshot windows" (SI terminology) based on a key selector.
TopK<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Comparison<TPayload>>, Int32)	Computes a time-sensitive top-k aggregate using "snapshot windows" (SI terminology) based on a key selector.
TopK<TKey,TPayload,T>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,T>>, Int32)	Computes a time-sensitive top-k aggregate using "snapshot windows" (SI terminology) based on a key selector.
TopK<TKey,TPayload,T>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,T>>, Expression<Comparison<T>>, Int32)	Computes a time-sensitive top-k aggregate using "snapshot windows" (SI terminology) based on a key selector with the provided ordering comparer.
TumblingWindowLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64, Int64)	Adjusts the lifetime of incoming events to implement, when used in combination with aggregates, tumbling windows. In this implementation each incoming event results in a single outgoing event, which means that subsequent aggregates only produce output when the input changes. For instance, if a single point event is received and the tumbleDuration and offset are 100 and 0 respectively, a single aggregate output is produced with a lifetime of 100 ticks.
Union<TKey,TPayload>(IStreamable<TKey,TPayload>, IStreamable<TKey,TPayload>)	Union is a temporal union that combines two streams of like schema
Unpivot<TKey,TInput,TPivotKey,TValue,TResult>(IStreamable<TKey, TInput>, Expression<Func<TResult>>, Expression<Func<TInput,TPivotKey>>, Expression<Func<TResult,String>>, Expression<Func<TResult,TValue>>)	Rotates a stream of payload objects into a stream of key-attribute-value triples corresponding to the data from the input payloads.
Where<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Boolean>>)	Performs a filter over a streamable, excluding rows for which the predicate evaluates to false.
WhereNotExists<TKey,TLeft,TRight>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>)	Performs a left anti-semi join without any join condition (join condition is true).
WhereNotExists<TKey,TLeft,TRight>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Int64)	Performs a left anti-semi join without any join condition (join condition is true).
WhereNotExists<TKey,TLeft,TRight,TJoinKey>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight, TJoinKey>>)	Performs a left anti-semi join using the passed in predicate as the join condition.
WhereNotExists<TKey,TLeft,TRight,TJoinKey>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight, TJoinKey>>, Int64)	Performs a left anti-semi join using the passed in predicate as the join condition.
WhereNotExists<TKey,TLeft,TRight,TJoinKey>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight, TJoinKey>>, Expression<Func<TLeft,TRight,Boolean>>)

Applies to