Streamable.Aggregate Method

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.

Overloads

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.
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.

public static Microsoft.StreamProcessing.IStreamable<TKey,TOutput> Aggregate<TKey,TInput,TState,TOutput> (this Microsoft.StreamProcessing.IStreamable<TKey,TInput> source, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState,TOutput>> aggregate);

static member Aggregate : Microsoft.StreamProcessing.IStreamable<'Key, 'Input> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'State, 'Output>> -> Microsoft.StreamProcessing.IStreamable<'Key, 'Output>

<Extension()>
Public Function Aggregate(Of TKey, TInput, TState, TOutput) (source As IStreamable(Of TKey, TInput), aggregate As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState, TOutput))) As IStreamable(Of TKey, TOutput)

Type Parameters

TKey

TInput

TState

TOutput

Parameters

source: IStreamable<TKey,TInput>

aggregate: Func<Window<TKey,TInput>,IAggregate<TInput,TState,TOutput>>

Returns

IStreamable<TKey,TOutput>

Applies to

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.

public static Microsoft.StreamProcessing.IStreamable<TKey,TOutput> Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TOutput> (this Microsoft.StreamProcessing.IStreamable<TKey,TInput> source, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState1,TOutput1>> aggregate1, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState2,TOutput2>> aggregate2, System.Linq.Expressions.Expression<Func<TOutput1,TOutput2,TOutput>> merger);

static member Aggregate : Microsoft.StreamProcessing.IStreamable<'Key, 'Input> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState1, 'TOutput1>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState2, 'TOutput2>> * System.Linq.Expressions.Expression<Func<'TOutput1, 'TOutput2, 'Output>> -> Microsoft.StreamProcessing.IStreamable<'Key, 'Output>

<Extension()>
Public Function Aggregate(Of TKey, TInput, TState1, TOutput1, TState2, TOutput2, TOutput) (source As IStreamable(Of TKey, TInput), aggregate1 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState1, TOutput1)), aggregate2 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState2, TOutput2)), merger As Expression(Of Func(Of TOutput1, TOutput2, TOutput))) As IStreamable(Of TKey, TOutput)

Type Parameters

TKey

TInput

TState1

TOutput1

TState2

TOutput2

TOutput

Parameters

source: IStreamable<TKey,TInput>

aggregate1: Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>

aggregate2: Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>

merger: Expression<Func<TOutput1,TOutput2,TOutput>>

Returns

IStreamable<TKey,TOutput>

Applies to

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.

public static Microsoft.StreamProcessing.IStreamable<TKey,TOutput> Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3,TOutput3,TOutput> (this Microsoft.StreamProcessing.IStreamable<TKey,TInput> source, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState1,TOutput1>> aggregate1, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState2,TOutput2>> aggregate2, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState3,TOutput3>> aggregate3, System.Linq.Expressions.Expression<Func<TOutput1,TOutput2,TOutput3,TOutput>> merger);

static member Aggregate : Microsoft.StreamProcessing.IStreamable<'Key, 'Input> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState1, 'TOutput1>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState2, 'TOutput2>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState3, 'TOutput3>> * System.Linq.Expressions.Expression<Func<'TOutput1, 'TOutput2, 'TOutput3, 'Output>> -> Microsoft.StreamProcessing.IStreamable<'Key, 'Output>

<Extension()>
Public Function Aggregate(Of TKey, TInput, TState1, TOutput1, TState2, TOutput2, TState3, TOutput3, TOutput) (source As IStreamable(Of TKey, TInput), aggregate1 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState1, TOutput1)), aggregate2 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState2, TOutput2)), aggregate3 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState3, TOutput3)), merger As Expression(Of Func(Of TOutput1, TOutput2, TOutput3, TOutput))) As IStreamable(Of TKey, TOutput)

Type Parameters

TKey

TInput

TState1

TOutput1

TState2

TOutput2

TState3

TOutput3

TOutput

Parameters

source: IStreamable<TKey,TInput>

aggregate1: Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>

aggregate2: Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>

aggregate3: Func<Window<TKey,TInput>,IAggregate<TInput,TState3,TOutput3>>

merger: Expression<Func<TOutput1,TOutput2,TOutput3,TOutput>>

Returns

IStreamable<TKey,TOutput>

Applies to

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.

public static Microsoft.StreamProcessing.IStreamable<TKey,TOutput> Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3,TOutput3,TState4,TOutput4,TOutput> (this Microsoft.StreamProcessing.IStreamable<TKey,TInput> source, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState1,TOutput1>> aggregate1, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState2,TOutput2>> aggregate2, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState3,TOutput3>> aggregate3, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState4,TOutput4>> aggregate4, System.Linq.Expressions.Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput>> merger);

static member Aggregate : Microsoft.StreamProcessing.IStreamable<'Key, 'Input> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState1, 'TOutput1>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState2, 'TOutput2>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState3, 'TOutput3>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState4, 'TOutput4>> * System.Linq.Expressions.Expression<Func<'TOutput1, 'TOutput2, 'TOutput3, 'TOutput4, 'Output>> -> Microsoft.StreamProcessing.IStreamable<'Key, 'Output>

<Extension()>
Public Function Aggregate(Of TKey, TInput, TState1, TOutput1, TState2, TOutput2, TState3, TOutput3, TState4, TOutput4, TOutput) (source As IStreamable(Of TKey, TInput), aggregate1 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState1, TOutput1)), aggregate2 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState2, TOutput2)), aggregate3 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState3, TOutput3)), aggregate4 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState4, TOutput4)), merger As Expression(Of Func(Of TOutput1, TOutput2, TOutput3, TOutput4, TOutput))) As IStreamable(Of TKey, TOutput)

Type Parameters

TKey

TInput

TState1

TOutput1

TState2

TOutput2

TState3

TOutput3

TState4

TOutput4

TOutput

Parameters

source: IStreamable<TKey,TInput>

aggregate1: Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>

aggregate2: Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>

aggregate3: Func<Window<TKey,TInput>,IAggregate<TInput,TState3,TOutput3>>

aggregate4: Func<Window<TKey,TInput>,IAggregate<TInput,TState4,TOutput4>>

merger: Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput>>

Returns

IStreamable<TKey,TOutput>

Applies to

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.

public static Microsoft.StreamProcessing.IStreamable<TKey,TOutput> Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TOutput> (this Microsoft.StreamProcessing.IStreamable<TKey,TInput> source, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState1,TOutput1>> aggregate1, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState2,TOutput2>> aggregate2, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState3,TOutput3>> aggregate3, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState4,TOutput4>> aggregate4, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState5,TOutput5>> aggregate5, System.Linq.Expressions.Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput>> merger);

static member Aggregate : Microsoft.StreamProcessing.IStreamable<'Key, 'Input> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState1, 'TOutput1>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState2, 'TOutput2>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState3, 'TOutput3>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState4, 'TOutput4>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState5, 'TOutput5>> * System.Linq.Expressions.Expression<Func<'TOutput1, 'TOutput2, 'TOutput3, 'TOutput4, 'TOutput5, 'Output>> -> Microsoft.StreamProcessing.IStreamable<'Key, 'Output>

<Extension()>
Public Function Aggregate(Of TKey, TInput, TState1, TOutput1, TState2, TOutput2, TState3, TOutput3, TState4, TOutput4, TState5, TOutput5, TOutput) (source As IStreamable(Of TKey, TInput), aggregate1 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState1, TOutput1)), aggregate2 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState2, TOutput2)), aggregate3 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState3, TOutput3)), aggregate4 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState4, TOutput4)), aggregate5 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState5, TOutput5)), merger As Expression(Of Func(Of TOutput1, TOutput2, TOutput3, TOutput4, TOutput5, TOutput))) As IStreamable(Of TKey, TOutput)

Type Parameters

TKey

TInput

TState1

TOutput1

TState2

TOutput2

TState3

TOutput3

TState4

TOutput4

TState5

TOutput5

TOutput

Parameters

source: IStreamable<TKey,TInput>

aggregate1: Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>

aggregate2: Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>

aggregate3: Func<Window<TKey,TInput>,IAggregate<TInput,TState3,TOutput3>>

aggregate4: Func<Window<TKey,TInput>,IAggregate<TInput,TState4,TOutput4>>

aggregate5: Func<Window<TKey,TInput>,IAggregate<TInput,TState5,TOutput5>>

merger: Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput>>

Returns

IStreamable<TKey,TOutput>

Applies to

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.

public static Microsoft.StreamProcessing.IStreamable<TKey,TOutput> Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TOutput> (this Microsoft.StreamProcessing.IStreamable<TKey,TInput> source, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState1,TOutput1>> aggregate1, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState2,TOutput2>> aggregate2, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState3,TOutput3>> aggregate3, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState4,TOutput4>> aggregate4, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState5,TOutput5>> aggregate5, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState6,TOutput6>> aggregate6, System.Linq.Expressions.Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput>> merger);

static member Aggregate : Microsoft.StreamProcessing.IStreamable<'Key, 'Input> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState1, 'TOutput1>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState2, 'TOutput2>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState3, 'TOutput3>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState4, 'TOutput4>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState5, 'TOutput5>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState6, 'TOutput6>> * System.Linq.Expressions.Expression<Func<'TOutput1, 'TOutput2, 'TOutput3, 'TOutput4, 'TOutput5, 'TOutput6, 'Output>> -> Microsoft.StreamProcessing.IStreamable<'Key, 'Output>

<Extension()>
Public Function Aggregate(Of TKey, TInput, TState1, TOutput1, TState2, TOutput2, TState3, TOutput3, TState4, TOutput4, TState5, TOutput5, TState6, TOutput6, TOutput) (source As IStreamable(Of TKey, TInput), aggregate1 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState1, TOutput1)), aggregate2 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState2, TOutput2)), aggregate3 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState3, TOutput3)), aggregate4 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState4, TOutput4)), aggregate5 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState5, TOutput5)), aggregate6 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState6, TOutput6)), merger As Expression(Of Func(Of TOutput1, TOutput2, TOutput3, TOutput4, TOutput5, TOutput6, TOutput))) As IStreamable(Of TKey, TOutput)

Type Parameters

TKey

TInput

TState1

TOutput1

TState2

TOutput2

TState3

TOutput3

TState4

TOutput4

TState5

TOutput5

TState6

TOutput6

TOutput

Parameters

source: IStreamable<TKey,TInput>

aggregate1: Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>

aggregate2: Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>

aggregate3: Func<Window<TKey,TInput>,IAggregate<TInput,TState3,TOutput3>>

aggregate4: Func<Window<TKey,TInput>,IAggregate<TInput,TState4,TOutput4>>

aggregate5: Func<Window<TKey,TInput>,IAggregate<TInput,TState5,TOutput5>>

aggregate6: Func<Window<TKey,TInput>,IAggregate<TInput,TState6,TOutput6>>

merger: Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput>>

Returns

IStreamable<TKey,TOutput>

Applies to

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.

public static Microsoft.StreamProcessing.IStreamable<TKey,TOutput> Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TState7,TOutput7,TOutput> (this Microsoft.StreamProcessing.IStreamable<TKey,TInput> source, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState1,TOutput1>> aggregate1, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState2,TOutput2>> aggregate2, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState3,TOutput3>> aggregate3, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState4,TOutput4>> aggregate4, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState5,TOutput5>> aggregate5, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState6,TOutput6>> aggregate6, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState7,TOutput7>> aggregate7, System.Linq.Expressions.Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput>> merger);

static member Aggregate : Microsoft.StreamProcessing.IStreamable<'Key, 'Input> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState1, 'TOutput1>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState2, 'TOutput2>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState3, 'TOutput3>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState4, 'TOutput4>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState5, 'TOutput5>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState6, 'TOutput6>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState7, 'TOutput7>> * System.Linq.Expressions.Expression<Func<'TOutput1, 'TOutput2, 'TOutput3, 'TOutput4, 'TOutput5, 'TOutput6, 'TOutput7, 'Output>> -> Microsoft.StreamProcessing.IStreamable<'Key, 'Output>

<Extension()>
Public Function Aggregate(Of TKey, TInput, TState1, TOutput1, TState2, TOutput2, TState3, TOutput3, TState4, TOutput4, TState5, TOutput5, TState6, TOutput6, TState7, TOutput7, TOutput) (source As IStreamable(Of TKey, TInput), aggregate1 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState1, TOutput1)), aggregate2 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState2, TOutput2)), aggregate3 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState3, TOutput3)), aggregate4 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState4, TOutput4)), aggregate5 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState5, TOutput5)), aggregate6 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState6, TOutput6)), aggregate7 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState7, TOutput7)), merger As Expression(Of Func(Of TOutput1, TOutput2, TOutput3, TOutput4, TOutput5, TOutput6, TOutput7, TOutput))) As IStreamable(Of TKey, TOutput)

Type Parameters

TKey

TInput

TState1

TOutput1

TState2

TOutput2

TState3

TOutput3

TState4

TOutput4

TState5

TOutput5

TState6

TOutput6

TState7

TOutput7

TOutput

Parameters

source: IStreamable<TKey,TInput>

aggregate1: Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>

aggregate2: Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>

aggregate3: Func<Window<TKey,TInput>,IAggregate<TInput,TState3,TOutput3>>

aggregate4: Func<Window<TKey,TInput>,IAggregate<TInput,TState4,TOutput4>>

aggregate5: Func<Window<TKey,TInput>,IAggregate<TInput,TState5,TOutput5>>

aggregate6: Func<Window<TKey,TInput>,IAggregate<TInput,TState6,TOutput6>>

aggregate7: Func<Window<TKey,TInput>,IAggregate<TInput,TState7,TOutput7>>

merger: Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput>>

Returns

IStreamable<TKey,TOutput>

Applies to

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.

public static Microsoft.StreamProcessing.IStreamable<TKey,TOutput> Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TState7,TOutput7,TState8,TOutput8,TOutput> (this Microsoft.StreamProcessing.IStreamable<TKey,TInput> source, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState1,TOutput1>> aggregate1, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState2,TOutput2>> aggregate2, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState3,TOutput3>> aggregate3, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState4,TOutput4>> aggregate4, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState5,TOutput5>> aggregate5, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState6,TOutput6>> aggregate6, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState7,TOutput7>> aggregate7, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState8,TOutput8>> aggregate8, System.Linq.Expressions.Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8,TOutput>> merger);

static member Aggregate : Microsoft.StreamProcessing.IStreamable<'Key, 'Input> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState1, 'TOutput1>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState2, 'TOutput2>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState3, 'TOutput3>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState4, 'TOutput4>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState5, 'TOutput5>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState6, 'TOutput6>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState7, 'TOutput7>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState8, 'TOutput8>> * System.Linq.Expressions.Expression<Func<'TOutput1, 'TOutput2, 'TOutput3, 'TOutput4, 'TOutput5, 'TOutput6, 'TOutput7, 'TOutput8, 'Output>> -> Microsoft.StreamProcessing.IStreamable<'Key, 'Output>

<Extension()>
Public Function Aggregate(Of TKey, TInput, TState1, TOutput1, TState2, TOutput2, TState3, TOutput3, TState4, TOutput4, TState5, TOutput5, TState6, TOutput6, TState7, TOutput7, TState8, TOutput8, TOutput) (source As IStreamable(Of TKey, TInput), aggregate1 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState1, TOutput1)), aggregate2 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState2, TOutput2)), aggregate3 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState3, TOutput3)), aggregate4 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState4, TOutput4)), aggregate5 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState5, TOutput5)), aggregate6 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState6, TOutput6)), aggregate7 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState7, TOutput7)), aggregate8 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState8, TOutput8)), merger As Expression(Of Func(Of TOutput1, TOutput2, TOutput3, TOutput4, TOutput5, TOutput6, TOutput7, TOutput8, TOutput))) As IStreamable(Of TKey, TOutput)

Type Parameters

TKey

TInput

TState1

TOutput1

TState2

TOutput2

TState3

TOutput3

TState4

TOutput4

TState5

TOutput5

TState6

TOutput6

TState7

TOutput7

TState8

TOutput8

TOutput

Parameters

source: IStreamable<TKey,TInput>

aggregate1: Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>

aggregate2: Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>

aggregate3: Func<Window<TKey,TInput>,IAggregate<TInput,TState3,TOutput3>>

aggregate4: Func<Window<TKey,TInput>,IAggregate<TInput,TState4,TOutput4>>

aggregate5: Func<Window<TKey,TInput>,IAggregate<TInput,TState5,TOutput5>>

aggregate6: Func<Window<TKey,TInput>,IAggregate<TInput,TState6,TOutput6>>

aggregate7: Func<Window<TKey,TInput>,IAggregate<TInput,TState7,TOutput7>>

aggregate8: Func<Window<TKey,TInput>,IAggregate<TInput,TState8,TOutput8>>

merger: Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8,TOutput>>

Returns

IStreamable<TKey,TOutput>

Applies to

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.

public static Microsoft.StreamProcessing.IStreamable<TKey,TOutput> Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TOutput> (this Microsoft.StreamProcessing.IStreamable<TKey,TInput> source, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState1,TOutput1>> aggregate1, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState2,TOutput2>> aggregate2, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState3,TOutput3>> aggregate3, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState4,TOutput4>> aggregate4, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState5,TOutput5>> aggregate5, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState6,TOutput6>> aggregate6, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState7,TOutput7>> aggregate7, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState8,TOutput8>> aggregate8, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState9,TOutput9>> aggregate9, System.Linq.Expressions.Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8,TOutput9,TOutput>> merger);

static member Aggregate : Microsoft.StreamProcessing.IStreamable<'Key, 'Input> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState1, 'TOutput1>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState2, 'TOutput2>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState3, 'TOutput3>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState4, 'TOutput4>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState5, 'TOutput5>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState6, 'TOutput6>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState7, 'TOutput7>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState8, 'TOutput8>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState9, 'TOutput9>> * System.Linq.Expressions.Expression<Func<'TOutput1, 'TOutput2, 'TOutput3, 'TOutput4, 'TOutput5, 'TOutput6, 'TOutput7, 'TOutput8, 'TOutput9, 'Output>> -> Microsoft.StreamProcessing.IStreamable<'Key, 'Output>

<Extension()>
Public Function Aggregate(Of TKey, TInput, TState1, TOutput1, TState2, TOutput2, TState3, TOutput3, TState4, TOutput4, TState5, TOutput5, TState6, TOutput6, TState7, TOutput7, TState8, TOutput8, TState9, TOutput9, TOutput) (source As IStreamable(Of TKey, TInput), aggregate1 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState1, TOutput1)), aggregate2 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState2, TOutput2)), aggregate3 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState3, TOutput3)), aggregate4 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState4, TOutput4)), aggregate5 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState5, TOutput5)), aggregate6 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState6, TOutput6)), aggregate7 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState7, TOutput7)), aggregate8 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState8, TOutput8)), aggregate9 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState9, TOutput9)), merger As Expression(Of Func(Of TOutput1, TOutput2, TOutput3, TOutput4, TOutput5, TOutput6, TOutput7, TOutput8, TOutput9, TOutput))) As IStreamable(Of TKey, TOutput)

Type Parameters

TKey

TInput

TState1

TOutput1

TState2

TOutput2

TState3

TOutput3

TState4

TOutput4

TState5

TOutput5

TState6

TOutput6

TState7

TOutput7

TState8

TOutput8

TState9

TOutput9

TOutput

Parameters

source: IStreamable<TKey,TInput>

aggregate1: Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>

aggregate2: Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>

aggregate3: Func<Window<TKey,TInput>,IAggregate<TInput,TState3,TOutput3>>

aggregate4: Func<Window<TKey,TInput>,IAggregate<TInput,TState4,TOutput4>>

aggregate5: Func<Window<TKey,TInput>,IAggregate<TInput,TState5,TOutput5>>

aggregate6: Func<Window<TKey,TInput>,IAggregate<TInput,TState6,TOutput6>>

aggregate7: Func<Window<TKey,TInput>,IAggregate<TInput,TState7,TOutput7>>

aggregate8: Func<Window<TKey,TInput>,IAggregate<TInput,TState8,TOutput8>>

aggregate9: Func<Window<TKey,TInput>,IAggregate<TInput,TState9,TOutput9>>

merger: Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8,TOutput9,TOutput>>

Returns

IStreamable<TKey,TOutput>

Applies to

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.

public static Microsoft.StreamProcessing.IStreamable<TKey,TOutput> Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10,TOutput10,TOutput> (this Microsoft.StreamProcessing.IStreamable<TKey,TInput> source, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState1,TOutput1>> aggregate1, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState2,TOutput2>> aggregate2, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState3,TOutput3>> aggregate3, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState4,TOutput4>> aggregate4, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState5,TOutput5>> aggregate5, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState6,TOutput6>> aggregate6, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState7,TOutput7>> aggregate7, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState8,TOutput8>> aggregate8, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState9,TOutput9>> aggregate9, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState10,TOutput10>> aggregate10, System.Linq.Expressions.Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8,TOutput9,TOutput10,TOutput>> merger);

static member Aggregate : Microsoft.StreamProcessing.IStreamable<'Key, 'Input> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState1, 'TOutput1>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState2, 'TOutput2>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState3, 'TOutput3>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState4, 'TOutput4>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState5, 'TOutput5>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState6, 'TOutput6>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState7, 'TOutput7>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState8, 'TOutput8>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState9, 'TOutput9>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState10, 'TOutput10>> * System.Linq.Expressions.Expression<Func<'TOutput1, 'TOutput2, 'TOutput3, 'TOutput4, 'TOutput5, 'TOutput6, 'TOutput7, 'TOutput8, 'TOutput9, 'TOutput10, 'Output>> -> Microsoft.StreamProcessing.IStreamable<'Key, 'Output>

<Extension()>
Public Function Aggregate(Of TKey, TInput, TState1, TOutput1, TState2, TOutput2, TState3, TOutput3, TState4, TOutput4, TState5, TOutput5, TState6, TOutput6, TState7, TOutput7, TState8, TOutput8, TState9, TOutput9, TState10, TOutput10, TOutput) (source As IStreamable(Of TKey, TInput), aggregate1 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState1, TOutput1)), aggregate2 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState2, TOutput2)), aggregate3 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState3, TOutput3)), aggregate4 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState4, TOutput4)), aggregate5 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState5, TOutput5)), aggregate6 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState6, TOutput6)), aggregate7 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState7, TOutput7)), aggregate8 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState8, TOutput8)), aggregate9 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState9, TOutput9)), aggregate10 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState10, TOutput10)), merger As Expression(Of Func(Of TOutput1, TOutput2, TOutput3, TOutput4, TOutput5, TOutput6, TOutput7, TOutput8, TOutput9, TOutput10, TOutput))) As IStreamable(Of TKey, TOutput)

Type Parameters

TKey

TInput

TState1

TOutput1

TState2

TOutput2

TState3

TOutput3

TState4

TOutput4

TState5

TOutput5

TState6

TOutput6

TState7

TOutput7

TState8

TOutput8

TState9

TOutput9

TState10

TOutput10

TOutput

Parameters

source: IStreamable<TKey,TInput>

aggregate1: Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>

aggregate2: Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>

aggregate3: Func<Window<TKey,TInput>,IAggregate<TInput,TState3,TOutput3>>

aggregate4: Func<Window<TKey,TInput>,IAggregate<TInput,TState4,TOutput4>>

aggregate5: Func<Window<TKey,TInput>,IAggregate<TInput,TState5,TOutput5>>

aggregate6: Func<Window<TKey,TInput>,IAggregate<TInput,TState6,TOutput6>>

aggregate7: Func<Window<TKey,TInput>,IAggregate<TInput,TState7,TOutput7>>

aggregate8: Func<Window<TKey,TInput>,IAggregate<TInput,TState8,TOutput8>>

aggregate9: Func<Window<TKey,TInput>,IAggregate<TInput,TState9,TOutput9>>

aggregate10: Func<Window<TKey,TInput>,IAggregate<TInput,TState10,TOutput10>>

merger: Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8,TOutput9,TOutput10,TOutput>>

Returns

IStreamable<TKey,TOutput>

Applies to

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.

public static Microsoft.StreamProcessing.IStreamable<TKey,TOutput> 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> (this Microsoft.StreamProcessing.IStreamable<TKey,TInput> source, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState1,TOutput1>> aggregate1, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState2,TOutput2>> aggregate2, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState3,TOutput3>> aggregate3, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState4,TOutput4>> aggregate4, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState5,TOutput5>> aggregate5, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState6,TOutput6>> aggregate6, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState7,TOutput7>> aggregate7, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState8,TOutput8>> aggregate8, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState9,TOutput9>> aggregate9, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState10,TOutput10>> aggregate10, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState11,TOutput11>> aggregate11, System.Linq.Expressions.Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8,TOutput9,TOutput10,TOutput11,TOutput>> merger);

static member Aggregate : Microsoft.StreamProcessing.IStreamable<'Key, 'Input> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState1, 'TOutput1>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState2, 'TOutput2>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState3, 'TOutput3>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState4, 'TOutput4>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState5, 'TOutput5>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState6, 'TOutput6>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState7, 'TOutput7>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState8, 'TOutput8>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState9, 'TOutput9>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState10, 'TOutput10>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState11, 'TOutput11>> * System.Linq.Expressions.Expression<Func<'TOutput1, 'TOutput2, 'TOutput3, 'TOutput4, 'TOutput5, 'TOutput6, 'TOutput7, 'TOutput8, 'TOutput9, 'TOutput10, 'TOutput11, 'Output>> -> Microsoft.StreamProcessing.IStreamable<'Key, 'Output>

<Extension()>
Public Function Aggregate(Of 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) (source As IStreamable(Of TKey, TInput), aggregate1 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState1, TOutput1)), aggregate2 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState2, TOutput2)), aggregate3 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState3, TOutput3)), aggregate4 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState4, TOutput4)), aggregate5 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState5, TOutput5)), aggregate6 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState6, TOutput6)), aggregate7 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState7, TOutput7)), aggregate8 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState8, TOutput8)), aggregate9 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState9, TOutput9)), aggregate10 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState10, TOutput10)), aggregate11 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState11, TOutput11)), merger As Expression(Of Func(Of TOutput1, TOutput2, TOutput3, TOutput4, TOutput5, TOutput6, TOutput7, TOutput8, TOutput9, TOutput10, TOutput11, TOutput))) As IStreamable(Of TKey, TOutput)

Type Parameters

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

Parameters

source: IStreamable<TKey,TInput>

aggregate1: Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>

aggregate2: Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>

aggregate3: Func<Window<TKey,TInput>,IAggregate<TInput,TState3,TOutput3>>

aggregate4: Func<Window<TKey,TInput>,IAggregate<TInput,TState4,TOutput4>>

aggregate5: Func<Window<TKey,TInput>,IAggregate<TInput,TState5,TOutput5>>

aggregate6: Func<Window<TKey,TInput>,IAggregate<TInput,TState6,TOutput6>>

aggregate7: Func<Window<TKey,TInput>,IAggregate<TInput,TState7,TOutput7>>

aggregate8: Func<Window<TKey,TInput>,IAggregate<TInput,TState8,TOutput8>>

aggregate9: Func<Window<TKey,TInput>,IAggregate<TInput,TState9,TOutput9>>

aggregate10: Func<Window<TKey,TInput>,IAggregate<TInput,TState10,TOutput10>>

aggregate11: Func<Window<TKey,TInput>,IAggregate<TInput,TState11,TOutput11>>

merger: Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8,TOutput9,TOutput10,TOutput11,TOutput>>

Returns

IStreamable<TKey,TOutput>

Applies to

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.

public static Microsoft.StreamProcessing.IStreamable<TKey,TOutput> 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> (this Microsoft.StreamProcessing.IStreamable<TKey,TInput> source, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState1,TOutput1>> aggregate1, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState2,TOutput2>> aggregate2, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState3,TOutput3>> aggregate3, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState4,TOutput4>> aggregate4, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState5,TOutput5>> aggregate5, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState6,TOutput6>> aggregate6, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState7,TOutput7>> aggregate7, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState8,TOutput8>> aggregate8, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState9,TOutput9>> aggregate9, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState10,TOutput10>> aggregate10, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState11,TOutput11>> aggregate11, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState12,TOutput12>> aggregate12, System.Linq.Expressions.Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8,TOutput9,TOutput10,TOutput11,TOutput12,TOutput>> merger);

static member Aggregate : Microsoft.StreamProcessing.IStreamable<'Key, 'Input> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState1, 'TOutput1>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState2, 'TOutput2>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState3, 'TOutput3>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState4, 'TOutput4>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState5, 'TOutput5>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState6, 'TOutput6>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState7, 'TOutput7>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState8, 'TOutput8>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState9, 'TOutput9>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState10, 'TOutput10>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState11, 'TOutput11>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState12, 'TOutput12>> * System.Linq.Expressions.Expression<Func<'TOutput1, 'TOutput2, 'TOutput3, 'TOutput4, 'TOutput5, 'TOutput6, 'TOutput7, 'TOutput8, 'TOutput9, 'TOutput10, 'TOutput11, 'TOutput12, 'Output>> -> Microsoft.StreamProcessing.IStreamable<'Key, 'Output>

<Extension()>
Public Function Aggregate(Of 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) (source As IStreamable(Of TKey, TInput), aggregate1 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState1, TOutput1)), aggregate2 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState2, TOutput2)), aggregate3 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState3, TOutput3)), aggregate4 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState4, TOutput4)), aggregate5 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState5, TOutput5)), aggregate6 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState6, TOutput6)), aggregate7 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState7, TOutput7)), aggregate8 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState8, TOutput8)), aggregate9 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState9, TOutput9)), aggregate10 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState10, TOutput10)), aggregate11 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState11, TOutput11)), aggregate12 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState12, TOutput12)), merger As Expression(Of Func(Of TOutput1, TOutput2, TOutput3, TOutput4, TOutput5, TOutput6, TOutput7, TOutput8, TOutput9, TOutput10, TOutput11, TOutput12, TOutput))) As IStreamable(Of TKey, TOutput)

Type Parameters

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

Parameters

source: IStreamable<TKey,TInput>

aggregate1: Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>

aggregate2: Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>

aggregate3: Func<Window<TKey,TInput>,IAggregate<TInput,TState3,TOutput3>>

aggregate4: Func<Window<TKey,TInput>,IAggregate<TInput,TState4,TOutput4>>

aggregate5: Func<Window<TKey,TInput>,IAggregate<TInput,TState5,TOutput5>>

aggregate6: Func<Window<TKey,TInput>,IAggregate<TInput,TState6,TOutput6>>

aggregate7: Func<Window<TKey,TInput>,IAggregate<TInput,TState7,TOutput7>>

aggregate8: Func<Window<TKey,TInput>,IAggregate<TInput,TState8,TOutput8>>

aggregate9: Func<Window<TKey,TInput>,IAggregate<TInput,TState9,TOutput9>>

aggregate10: Func<Window<TKey,TInput>,IAggregate<TInput,TState10,TOutput10>>

aggregate11: Func<Window<TKey,TInput>,IAggregate<TInput,TState11,TOutput11>>

aggregate12: Func<Window<TKey,TInput>,IAggregate<TInput,TState12,TOutput12>>

merger: Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8,TOutput9,TOutput10,TOutput11,TOutput12,TOutput>>

Returns

IStreamable<TKey,TOutput>

Applies to

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.

public static Microsoft.StreamProcessing.IStreamable<TKey,TOutput> 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> (this Microsoft.StreamProcessing.IStreamable<TKey,TInput> source, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState1,TOutput1>> aggregate1, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState2,TOutput2>> aggregate2, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState3,TOutput3>> aggregate3, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState4,TOutput4>> aggregate4, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState5,TOutput5>> aggregate5, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState6,TOutput6>> aggregate6, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState7,TOutput7>> aggregate7, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState8,TOutput8>> aggregate8, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState9,TOutput9>> aggregate9, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState10,TOutput10>> aggregate10, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState11,TOutput11>> aggregate11, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState12,TOutput12>> aggregate12, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState13,TOutput13>> aggregate13, System.Linq.Expressions.Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8,TOutput9,TOutput10,TOutput11,TOutput12,TOutput13,TOutput>> merger);

static member Aggregate : Microsoft.StreamProcessing.IStreamable<'Key, 'Input> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState1, 'TOutput1>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState2, 'TOutput2>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState3, 'TOutput3>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState4, 'TOutput4>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState5, 'TOutput5>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState6, 'TOutput6>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState7, 'TOutput7>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState8, 'TOutput8>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState9, 'TOutput9>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState10, 'TOutput10>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState11, 'TOutput11>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState12, 'TOutput12>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState13, 'TOutput13>> * System.Linq.Expressions.Expression<Func<'TOutput1, 'TOutput2, 'TOutput3, 'TOutput4, 'TOutput5, 'TOutput6, 'TOutput7, 'TOutput8, 'TOutput9, 'TOutput10, 'TOutput11, 'TOutput12, 'TOutput13, 'Output>> -> Microsoft.StreamProcessing.IStreamable<'Key, 'Output>

<Extension()>
Public Function Aggregate(Of 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) (source As IStreamable(Of TKey, TInput), aggregate1 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState1, TOutput1)), aggregate2 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState2, TOutput2)), aggregate3 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState3, TOutput3)), aggregate4 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState4, TOutput4)), aggregate5 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState5, TOutput5)), aggregate6 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState6, TOutput6)), aggregate7 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState7, TOutput7)), aggregate8 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState8, TOutput8)), aggregate9 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState9, TOutput9)), aggregate10 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState10, TOutput10)), aggregate11 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState11, TOutput11)), aggregate12 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState12, TOutput12)), aggregate13 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState13, TOutput13)), merger As Expression(Of Func(Of TOutput1, TOutput2, TOutput3, TOutput4, TOutput5, TOutput6, TOutput7, TOutput8, TOutput9, TOutput10, TOutput11, TOutput12, TOutput13, TOutput))) As IStreamable(Of TKey, TOutput)

Type Parameters

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

Parameters

source: IStreamable<TKey,TInput>

aggregate1: Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>

aggregate2: Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>

aggregate3: Func<Window<TKey,TInput>,IAggregate<TInput,TState3,TOutput3>>

aggregate4: Func<Window<TKey,TInput>,IAggregate<TInput,TState4,TOutput4>>

aggregate5: Func<Window<TKey,TInput>,IAggregate<TInput,TState5,TOutput5>>

aggregate6: Func<Window<TKey,TInput>,IAggregate<TInput,TState6,TOutput6>>

aggregate7: Func<Window<TKey,TInput>,IAggregate<TInput,TState7,TOutput7>>

aggregate8: Func<Window<TKey,TInput>,IAggregate<TInput,TState8,TOutput8>>

aggregate9: Func<Window<TKey,TInput>,IAggregate<TInput,TState9,TOutput9>>

aggregate10: Func<Window<TKey,TInput>,IAggregate<TInput,TState10,TOutput10>>

aggregate11: Func<Window<TKey,TInput>,IAggregate<TInput,TState11,TOutput11>>

aggregate12: Func<Window<TKey,TInput>,IAggregate<TInput,TState12,TOutput12>>

aggregate13: Func<Window<TKey,TInput>,IAggregate<TInput,TState13,TOutput13>>

merger: Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8,TOutput9,TOutput10,TOutput11,TOutput12,TOutput13,TOutput>>

Returns

IStreamable<TKey,TOutput>

Applies to

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.

public static Microsoft.StreamProcessing.IStreamable<TKey,TOutput> 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> (this Microsoft.StreamProcessing.IStreamable<TKey,TInput> source, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState1,TOutput1>> aggregate1, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState2,TOutput2>> aggregate2, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState3,TOutput3>> aggregate3, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState4,TOutput4>> aggregate4, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState5,TOutput5>> aggregate5, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState6,TOutput6>> aggregate6, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState7,TOutput7>> aggregate7, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState8,TOutput8>> aggregate8, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState9,TOutput9>> aggregate9, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState10,TOutput10>> aggregate10, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState11,TOutput11>> aggregate11, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState12,TOutput12>> aggregate12, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState13,TOutput13>> aggregate13, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState14,TOutput14>> aggregate14, System.Linq.Expressions.Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8,TOutput9,TOutput10,TOutput11,TOutput12,TOutput13,TOutput14,TOutput>> merger);

static member Aggregate : Microsoft.StreamProcessing.IStreamable<'Key, 'Input> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState1, 'TOutput1>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState2, 'TOutput2>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState3, 'TOutput3>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState4, 'TOutput4>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState5, 'TOutput5>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState6, 'TOutput6>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState7, 'TOutput7>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState8, 'TOutput8>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState9, 'TOutput9>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState10, 'TOutput10>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState11, 'TOutput11>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState12, 'TOutput12>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState13, 'TOutput13>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState14, 'TOutput14>> * System.Linq.Expressions.Expression<Func<'TOutput1, 'TOutput2, 'TOutput3, 'TOutput4, 'TOutput5, 'TOutput6, 'TOutput7, 'TOutput8, 'TOutput9, 'TOutput10, 'TOutput11, 'TOutput12, 'TOutput13, 'TOutput14, 'Output>> -> Microsoft.StreamProcessing.IStreamable<'Key, 'Output>

<Extension()>
Public Function Aggregate(Of 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) (source As IStreamable(Of TKey, TInput), aggregate1 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState1, TOutput1)), aggregate2 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState2, TOutput2)), aggregate3 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState3, TOutput3)), aggregate4 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState4, TOutput4)), aggregate5 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState5, TOutput5)), aggregate6 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState6, TOutput6)), aggregate7 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState7, TOutput7)), aggregate8 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState8, TOutput8)), aggregate9 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState9, TOutput9)), aggregate10 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState10, TOutput10)), aggregate11 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState11, TOutput11)), aggregate12 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState12, TOutput12)), aggregate13 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState13, TOutput13)), aggregate14 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState14, TOutput14)), merger As Expression(Of Func(Of TOutput1, TOutput2, TOutput3, TOutput4, TOutput5, TOutput6, TOutput7, TOutput8, TOutput9, TOutput10, TOutput11, TOutput12, TOutput13, TOutput14, TOutput))) As IStreamable(Of TKey, TOutput)

Type Parameters

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

Parameters

source: IStreamable<TKey,TInput>

aggregate1: Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>

aggregate2: Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>

aggregate3: Func<Window<TKey,TInput>,IAggregate<TInput,TState3,TOutput3>>

aggregate4: Func<Window<TKey,TInput>,IAggregate<TInput,TState4,TOutput4>>

aggregate5: Func<Window<TKey,TInput>,IAggregate<TInput,TState5,TOutput5>>

aggregate6: Func<Window<TKey,TInput>,IAggregate<TInput,TState6,TOutput6>>

aggregate7: Func<Window<TKey,TInput>,IAggregate<TInput,TState7,TOutput7>>

aggregate8: Func<Window<TKey,TInput>,IAggregate<TInput,TState8,TOutput8>>

aggregate9: Func<Window<TKey,TInput>,IAggregate<TInput,TState9,TOutput9>>

aggregate10: Func<Window<TKey,TInput>,IAggregate<TInput,TState10,TOutput10>>

aggregate11: Func<Window<TKey,TInput>,IAggregate<TInput,TState11,TOutput11>>

aggregate12: Func<Window<TKey,TInput>,IAggregate<TInput,TState12,TOutput12>>

aggregate13: Func<Window<TKey,TInput>,IAggregate<TInput,TState13,TOutput13>>

aggregate14: Func<Window<TKey,TInput>,IAggregate<TInput,TState14,TOutput14>>

merger: Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8,TOutput9,TOutput10,TOutput11,TOutput12,TOutput13,TOutput14,TOutput>>

Returns

IStreamable<TKey,TOutput>

Applies to

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.

public static Microsoft.StreamProcessing.IStreamable<TKey,TOutput> 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> (this Microsoft.StreamProcessing.IStreamable<TKey,TInput> source, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState1,TOutput1>> aggregate1, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState2,TOutput2>> aggregate2, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState3,TOutput3>> aggregate3, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState4,TOutput4>> aggregate4, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState5,TOutput5>> aggregate5, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState6,TOutput6>> aggregate6, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState7,TOutput7>> aggregate7, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState8,TOutput8>> aggregate8, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState9,TOutput9>> aggregate9, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState10,TOutput10>> aggregate10, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState11,TOutput11>> aggregate11, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState12,TOutput12>> aggregate12, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState13,TOutput13>> aggregate13, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState14,TOutput14>> aggregate14, Func<Microsoft.StreamProcessing.Window<TKey,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState15,TOutput15>> aggregate15, System.Linq.Expressions.Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8,TOutput9,TOutput10,TOutput11,TOutput12,TOutput13,TOutput14,TOutput15,TOutput>> merger);

static member Aggregate : Microsoft.StreamProcessing.IStreamable<'Key, 'Input> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState1, 'TOutput1>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState2, 'TOutput2>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState3, 'TOutput3>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState4, 'TOutput4>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState5, 'TOutput5>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState6, 'TOutput6>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState7, 'TOutput7>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState8, 'TOutput8>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState9, 'TOutput9>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState10, 'TOutput10>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState11, 'TOutput11>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState12, 'TOutput12>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState13, 'TOutput13>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState14, 'TOutput14>> * Func<Microsoft.StreamProcessing.Window<'Key, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState15, 'TOutput15>> * System.Linq.Expressions.Expression<Func<'TOutput1, 'TOutput2, 'TOutput3, 'TOutput4, 'TOutput5, 'TOutput6, 'TOutput7, 'TOutput8, 'TOutput9, 'TOutput10, 'TOutput11, 'TOutput12, 'TOutput13, 'TOutput14, 'TOutput15, 'Output>> -> Microsoft.StreamProcessing.IStreamable<'Key, 'Output>

<Extension()>
Public Function Aggregate(Of 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) (source As IStreamable(Of TKey, TInput), aggregate1 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState1, TOutput1)), aggregate2 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState2, TOutput2)), aggregate3 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState3, TOutput3)), aggregate4 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState4, TOutput4)), aggregate5 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState5, TOutput5)), aggregate6 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState6, TOutput6)), aggregate7 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState7, TOutput7)), aggregate8 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState8, TOutput8)), aggregate9 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState9, TOutput9)), aggregate10 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState10, TOutput10)), aggregate11 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState11, TOutput11)), aggregate12 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState12, TOutput12)), aggregate13 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState13, TOutput13)), aggregate14 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState14, TOutput14)), aggregate15 As Func(Of Window(Of TKey, TInput), IAggregate(Of TInput, TState15, TOutput15)), merger As Expression(Of Func(Of TOutput1, TOutput2, TOutput3, TOutput4, TOutput5, TOutput6, TOutput7, TOutput8, TOutput9, TOutput10, TOutput11, TOutput12, TOutput13, TOutput14, TOutput15, TOutput))) As IStreamable(Of TKey, TOutput)

Type Parameters

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

Parameters

source: IStreamable<TKey,TInput>

aggregate1: Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>

aggregate2: Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>

aggregate3: Func<Window<TKey,TInput>,IAggregate<TInput,TState3,TOutput3>>

aggregate4: Func<Window<TKey,TInput>,IAggregate<TInput,TState4,TOutput4>>

aggregate5: Func<Window<TKey,TInput>,IAggregate<TInput,TState5,TOutput5>>

aggregate6: Func<Window<TKey,TInput>,IAggregate<TInput,TState6,TOutput6>>

aggregate7: Func<Window<TKey,TInput>,IAggregate<TInput,TState7,TOutput7>>

aggregate8: Func<Window<TKey,TInput>,IAggregate<TInput,TState8,TOutput8>>

aggregate9: Func<Window<TKey,TInput>,IAggregate<TInput,TState9,TOutput9>>

aggregate10: Func<Window<TKey,TInput>,IAggregate<TInput,TState10,TOutput10>>

aggregate11: Func<Window<TKey,TInput>,IAggregate<TInput,TState11,TOutput11>>

aggregate12: Func<Window<TKey,TInput>,IAggregate<TInput,TState12,TOutput12>>

aggregate13: Func<Window<TKey,TInput>,IAggregate<TInput,TState13,TOutput13>>

aggregate14: Func<Window<TKey,TInput>,IAggregate<TInput,TState14,TOutput14>>

aggregate15: Func<Window<TKey,TInput>,IAggregate<TInput,TState15,TOutput15>>

merger: Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8,TOutput9,TOutput10,TOutput11,TOutput12,TOutput13,TOutput14,TOutput15,TOutput>>

Returns

IStreamable<TKey,TOutput>

Applies to

Streamable.Aggregate Method

Definition

Overloads

Aggregate<TKey,TInput,TState,TOutput>(IStreamable<TKey,TInput>, Func<Window<TKey,TInput>,IAggregate<TInput,TState,TOutput>>)

Type Parameters

Parameters

Returns

Applies to

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>>)

Type Parameters

Parameters

Returns

Applies to

Type Parameters

Parameters

Returns

Applies to

Type Parameters

Parameters

Returns

Applies to

Type Parameters

Parameters

Returns

Applies to

Type Parameters

Parameters

Returns

Applies to

Type Parameters

Parameters

Returns

Applies to

Type Parameters

Parameters

Returns

Applies to

Type Parameters

Parameters

Returns

Applies to

Type Parameters

Parameters

Returns

Applies to

Type Parameters

Parameters

Returns

Applies to

Type Parameters

Parameters

Returns

Applies to

Type Parameters

Parameters

Returns

Applies to

Type Parameters

Parameters

Returns

Applies to

Type Parameters

Parameters

Returns

Applies to

Additional resources