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

AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TOutput>(IStreamable<Empty, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Expression<Func<TInnerKey, TOutput1,TOutput>>)	Applies multiple aggregates to snapshot windows on the input stream relative to the selected grouping key.
AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TState2,TOutput2, TOutput,TResult>(IStreamable<Empty,TInput>, Expression<Func<TInput, TInnerKey>>, Func<Window<CompoundGroupKey<Empty,TInnerKey>,TInput>, IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Expression<Func<TOutput1, TOutput2,TOutput>>, Expression<Func<TInnerKey,TOutput,TResult>>)	Applies multiple aggregates to snapshot windows on the input stream relative to the selected grouping key.
AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TState2,TOutput2, TState3,TOutput3,TOutput,TResult>(IStreamable<Empty,TInput>, Expression<Func<TInput, TInnerKey>>, Func<Window<CompoundGroupKey<Empty,TInnerKey>,TInput>, IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput>>, Expression<Func<TInnerKey,TOutput, TResult>>)	Applies multiple aggregates to snapshot windows on the input stream relative to the selected grouping key.
AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TState2,TOutput2, TState3,TOutput3,TState4,TOutput4,TOutput,TResult>(IStreamable<Empty, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput>>, Expression<Func<TInnerKey, TOutput,TResult>>)	Applies multiple aggregates to snapshot windows on the input stream relative to the selected grouping key.
AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TState2,TOutput2, TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TOutput,TResult>(IStreamable<Empty, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput5,TOutput>>, Expression<Func<TInnerKey, TOutput,TResult>>)	Applies multiple aggregates to snapshot windows on the input stream relative to the selected grouping key.
AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TState2,TOutput2, TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6, TOutput,TResult>(IStreamable<Empty,TInput>, Expression<Func<TInput, TInnerKey>>, Func<Window<CompoundGroupKey<Empty,TInnerKey>,TInput>, IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput>>, Expression<Func<TInnerKey, TOutput,TResult>>)	Applies multiple aggregates to snapshot windows on the input stream relative to the selected grouping key.
AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TState2,TOutput2, TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6, TState7,TOutput7,TOutput,TResult>(IStreamable<Empty,TInput>, Expression<Func<TInput, TInnerKey>>, Func<Window<CompoundGroupKey<Empty,TInnerKey>,TInput>, IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput>>, Expression<Func<TInnerKey,TOutput,TResult>>)	Applies multiple aggregates to snapshot windows on the input stream relative to the selected grouping key.
AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TState2,TOutput2, TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6, TState7,TOutput7,TState8,TOutput8,TOutput,TResult>(IStreamable<Empty, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8, TOutput>>, Expression<Func<TInnerKey,TOutput,TResult>>)	Applies multiple aggregates to snapshot windows on the input stream relative to the selected grouping key.
AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TState2,TOutput2, TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6, TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TOutput,TResult>(IStreamable<Empty, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8, TOutput9,TOutput>>, Expression<Func<TInnerKey,TOutput,TResult>>)	Applies multiple aggregates to snapshot windows on the input stream relative to the selected grouping key.
AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TState2,TOutput2, TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6, TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10,TOutput10, TOutput,TResult>(IStreamable<Empty,TInput>, Expression<Func<TInput, TInnerKey>>, Func<Window<CompoundGroupKey<Empty,TInnerKey>,TInput>, IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8, TOutput9,TOutput10,TOutput>>, Expression<Func<TInnerKey,TOutput, TResult>>)	Applies multiple aggregates to snapshot windows on the input stream relative to the selected grouping key.
AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TState2,TOutput2, TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6, TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10,TOutput10, TState11,TOutput11,TOutput,TResult>(IStreamable<Empty,TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8, TOutput9,TOutput10,TOutput11,TOutput>>, Expression<Func<TInnerKey, TOutput,TResult>>)	Applies multiple aggregates to snapshot windows on the input stream relative to the selected grouping key.
AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TState2,TOutput2, TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6, TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10,TOutput10, TState11,TOutput11,TState12,TOutput12,TOutput,TResult>(IStreamable<Empty, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState12,TOutput12>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8, TOutput9,TOutput10,TOutput11,TOutput12,TOutput>>, Expression<Func<TInnerKey, TOutput,TResult>>)	Applies multiple aggregates to snapshot windows on the input stream relative to the selected grouping key.
AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TState2,TOutput2, TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6, TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10,TOutput10, TState11,TOutput11,TState12,TOutput12,TState13,TOutput13,TOutput, TResult>(IStreamable<Empty,TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput, TState1,TOutput1>>, Func<Window<CompoundGroupKey<Empty,TInnerKey>, TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState12,TOutput12>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState13,TOutput13>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8, TOutput9,TOutput10,TOutput11,TOutput12,TOutput13,TOutput>>, Expression<Func<TInnerKey, TOutput,TResult>>)	Applies multiple aggregates to snapshot windows on the input stream relative to the selected grouping key.
AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TState2,TOutput2, TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6, TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10,TOutput10, TState11,TOutput11,TState12,TOutput12,TState13,TOutput13,TState14, TOutput14,TOutput,TResult>(IStreamable<Empty,TInput>, Expression<Func<TInput, TInnerKey>>, Func<Window<CompoundGroupKey<Empty,TInnerKey>,TInput>, IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState12,TOutput12>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState13,TOutput13>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState14,TOutput14>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8, TOutput9,TOutput10,TOutput11,TOutput12,TOutput13,TOutput14,TOutput>>, Expression<Func<TInnerKey,TOutput,TResult>>)	Applies multiple aggregates to snapshot windows on the input stream relative to the selected grouping key.
AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TState2,TOutput2, TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6, TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10,TOutput10, TState11,TOutput11,TState12,TOutput12,TState13,TOutput13,TState14, TOutput14,TState15,TOutput15,TOutput,TResult>(IStreamable<Empty, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState12,TOutput12>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState13,TOutput13>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState14,TOutput14>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState15,TOutput15>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8, TOutput9,TOutput10,TOutput11,TOutput12,TOutput13,TOutput14,TOutput15, TOutput>>, Expression<Func<TInnerKey,TOutput,TResult>>)	Applies multiple aggregates to snapshot windows on the input stream relative to the selected grouping key.

AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TOutput>(IStreamable<Empty, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Expression<Func<TInnerKey, TOutput1,TOutput>>)

Applies multiple aggregates to snapshot windows on the input stream relative to the selected grouping key.

public static Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty,TOutput> AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TOutput> (this Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty,TInput> source, System.Linq.Expressions.Expression<Func<TInput,TInnerKey>> keySelector, Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty,TInnerKey>,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState1,TOutput1>> aggregate, System.Linq.Expressions.Expression<Func<TInnerKey,TOutput1,TOutput>> merger);

static member AggregateByKey : Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty, 'Input> * System.Linq.Expressions.Expression<Func<'Input, 'InnerKey>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState1, 'TOutput1>> * System.Linq.Expressions.Expression<Func<'InnerKey, 'TOutput1, 'Output>> -> Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty, 'Output>

<Extension()>
Public Function AggregateByKey(Of TInput, TInnerKey, TState1, TOutput1, TOutput) (source As IStreamable(Of Empty, TInput), keySelector As Expression(Of Func(Of TInput, TInnerKey)), aggregate As Func(Of Window(Of CompoundGroupKey(Of Empty, TInnerKey), TInput), IAggregate(Of TInput, TState1, TOutput1)), merger As Expression(Of Func(Of TInnerKey, TOutput1, TOutput))) As IStreamable(Of Empty, TOutput)

Type Parameters

TInput

TInnerKey

TState1

TOutput1

TOutput

Parameters

source: IStreamable<Empty,TInput>

keySelector: Expression<Func<TInput,TInnerKey>>

aggregate: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>

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

Returns

IStreamable<Empty,TOutput>

Applies to

AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TState2,TOutput2, TOutput,TResult>(IStreamable<Empty,TInput>, Expression<Func<TInput, TInnerKey>>, Func<Window<CompoundGroupKey<Empty,TInnerKey>,TInput>, IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Expression<Func<TOutput1, TOutput2,TOutput>>, Expression<Func<TInnerKey,TOutput,TResult>>)

Applies multiple aggregates to snapshot windows on the input stream relative to the selected grouping key.

public static Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty,TResult> AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TState2,TOutput2,TOutput,TResult> (this Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty,TInput> source, System.Linq.Expressions.Expression<Func<TInput,TInnerKey>> keySelector, Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty,TInnerKey>,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState1,TOutput1>> aggregate1, Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty,TInnerKey>,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState2,TOutput2>> aggregate2, System.Linq.Expressions.Expression<Func<TOutput1,TOutput2,TOutput>> merger, System.Linq.Expressions.Expression<Func<TInnerKey,TOutput,TResult>> resultSelector);

static member AggregateByKey : Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty, 'Input> * System.Linq.Expressions.Expression<Func<'Input, 'InnerKey>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState1, 'TOutput1>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState2, 'TOutput2>> * System.Linq.Expressions.Expression<Func<'TOutput1, 'TOutput2, 'Output>> * System.Linq.Expressions.Expression<Func<'InnerKey, 'Output, 'Result>> -> Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty, 'Result>

<Extension()>
Public Function AggregateByKey(Of TInput, TInnerKey, TState1, TOutput1, TState2, TOutput2, TOutput, TResult) (source As IStreamable(Of Empty, TInput), keySelector As Expression(Of Func(Of TInput, TInnerKey)), aggregate1 As Func(Of Window(Of CompoundGroupKey(Of Empty, TInnerKey), TInput), IAggregate(Of TInput, TState1, TOutput1)), aggregate2 As Func(Of Window(Of CompoundGroupKey(Of Empty, TInnerKey), TInput), IAggregate(Of TInput, TState2, TOutput2)), merger As Expression(Of Func(Of TOutput1, TOutput2, TOutput)), resultSelector As Expression(Of Func(Of TInnerKey, TOutput, TResult))) As IStreamable(Of Empty, TResult)

Type Parameters

TInput

TInnerKey

TState1

TOutput1

TState2

TOutput2

TOutput

TResult

Parameters

source: IStreamable<Empty,TInput>

keySelector: Expression<Func<TInput,TInnerKey>>

aggregate1: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>

aggregate2: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>

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

resultSelector: Expression<Func<TInnerKey,TOutput,TResult>>

Returns

IStreamable<Empty,TResult>

Applies to

AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TState2,TOutput2, TState3,TOutput3,TOutput,TResult>(IStreamable<Empty,TInput>, Expression<Func<TInput, TInnerKey>>, Func<Window<CompoundGroupKey<Empty,TInnerKey>,TInput>, IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput>>, Expression<Func<TInnerKey,TOutput, TResult>>)

Applies multiple aggregates to snapshot windows on the input stream relative to the selected grouping key.

public static Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty,TResult> AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TState2,TOutput2,TState3,TOutput3,TOutput,TResult> (this Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty,TInput> source, System.Linq.Expressions.Expression<Func<TInput,TInnerKey>> keySelector, Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty,TInnerKey>,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState1,TOutput1>> aggregate1, Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty,TInnerKey>,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState2,TOutput2>> aggregate2, Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty,TInnerKey>,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState3,TOutput3>> aggregate3, System.Linq.Expressions.Expression<Func<TOutput1,TOutput2,TOutput3,TOutput>> merger, System.Linq.Expressions.Expression<Func<TInnerKey,TOutput,TResult>> resultSelector);

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

<Extension()>
Public Function AggregateByKey(Of TInput, TInnerKey, TState1, TOutput1, TState2, TOutput2, TState3, TOutput3, TOutput, TResult) (source As IStreamable(Of Empty, TInput), keySelector As Expression(Of Func(Of TInput, TInnerKey)), aggregate1 As Func(Of Window(Of CompoundGroupKey(Of Empty, TInnerKey), TInput), IAggregate(Of TInput, TState1, TOutput1)), aggregate2 As Func(Of Window(Of CompoundGroupKey(Of Empty, TInnerKey), TInput), IAggregate(Of TInput, TState2, TOutput2)), aggregate3 As Func(Of Window(Of CompoundGroupKey(Of Empty, TInnerKey), TInput), IAggregate(Of TInput, TState3, TOutput3)), merger As Expression(Of Func(Of TOutput1, TOutput2, TOutput3, TOutput)), resultSelector As Expression(Of Func(Of TInnerKey, TOutput, TResult))) As IStreamable(Of Empty, TResult)

Type Parameters

TInput

TInnerKey

TState1

TOutput1

TState2

TOutput2

TState3

TOutput3

TOutput

TResult

Parameters

source: IStreamable<Empty,TInput>

keySelector: Expression<Func<TInput,TInnerKey>>

aggregate1: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>

aggregate2: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>

aggregate3: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>

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

resultSelector: Expression<Func<TInnerKey,TOutput,TResult>>

Returns

IStreamable<Empty,TResult>

Applies to

AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TState2,TOutput2, TState3,TOutput3,TState4,TOutput4,TOutput,TResult>(IStreamable<Empty, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput>>, Expression<Func<TInnerKey, TOutput,TResult>>)

Applies multiple aggregates to snapshot windows on the input stream relative to the selected grouping key.

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

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

<Extension()>
Public Function AggregateByKey(Of TInput, TInnerKey, TState1, TOutput1, TState2, TOutput2, TState3, TOutput3, TState4, TOutput4, TOutput, TResult) (source As IStreamable(Of Empty, TInput), keySelector As Expression(Of Func(Of TInput, TInnerKey)), aggregate1 As Func(Of Window(Of CompoundGroupKey(Of Empty, TInnerKey), TInput), IAggregate(Of TInput, TState1, TOutput1)), aggregate2 As Func(Of Window(Of CompoundGroupKey(Of Empty, TInnerKey), TInput), IAggregate(Of TInput, TState2, TOutput2)), aggregate3 As Func(Of Window(Of CompoundGroupKey(Of Empty, TInnerKey), TInput), IAggregate(Of TInput, TState3, TOutput3)), aggregate4 As Func(Of Window(Of CompoundGroupKey(Of Empty, TInnerKey), TInput), IAggregate(Of TInput, TState4, TOutput4)), merger As Expression(Of Func(Of TOutput1, TOutput2, TOutput3, TOutput4, TOutput)), resultSelector As Expression(Of Func(Of TInnerKey, TOutput, TResult))) As IStreamable(Of Empty, TResult)

Type Parameters

TInput

TInnerKey

TState1

TOutput1

TState2

TOutput2

TState3

TOutput3

TState4

TOutput4

TOutput

TResult

Parameters

source: IStreamable<Empty,TInput>

keySelector: Expression<Func<TInput,TInnerKey>>

aggregate1: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>

aggregate2: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>

aggregate3: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>

aggregate4: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>

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

resultSelector: Expression<Func<TInnerKey,TOutput,TResult>>

Returns

IStreamable<Empty,TResult>

Applies to

AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TState2,TOutput2, TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TOutput,TResult>(IStreamable<Empty, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput5,TOutput>>, Expression<Func<TInnerKey, TOutput,TResult>>)

Applies multiple aggregates to snapshot windows on the input stream relative to the selected grouping key.

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

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

<Extension()>
Public Function AggregateByKey(Of TInput, TInnerKey, TState1, TOutput1, TState2, TOutput2, TState3, TOutput3, TState4, TOutput4, TState5, TOutput5, TOutput, TResult) (source As IStreamable(Of Empty, TInput), keySelector As Expression(Of Func(Of TInput, TInnerKey)), aggregate1 As Func(Of Window(Of CompoundGroupKey(Of Empty, TInnerKey), TInput), IAggregate(Of TInput, TState1, TOutput1)), aggregate2 As Func(Of Window(Of CompoundGroupKey(Of Empty, TInnerKey), TInput), IAggregate(Of TInput, TState2, TOutput2)), aggregate3 As Func(Of Window(Of CompoundGroupKey(Of Empty, TInnerKey), TInput), IAggregate(Of TInput, TState3, TOutput3)), aggregate4 As Func(Of Window(Of CompoundGroupKey(Of Empty, TInnerKey), TInput), IAggregate(Of TInput, TState4, TOutput4)), aggregate5 As Func(Of Window(Of CompoundGroupKey(Of Empty, TInnerKey), TInput), IAggregate(Of TInput, TState5, TOutput5)), merger As Expression(Of Func(Of TOutput1, TOutput2, TOutput3, TOutput4, TOutput5, TOutput)), resultSelector As Expression(Of Func(Of TInnerKey, TOutput, TResult))) As IStreamable(Of Empty, TResult)

Type Parameters

TInput

TInnerKey

TState1

TOutput1

TState2

TOutput2

TState3

TOutput3

TState4

TOutput4

TState5

TOutput5

TOutput

TResult

Parameters

source: IStreamable<Empty,TInput>

keySelector: Expression<Func<TInput,TInnerKey>>

aggregate1: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>

aggregate2: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>

aggregate3: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>

aggregate4: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>

aggregate5: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>

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

resultSelector: Expression<Func<TInnerKey,TOutput,TResult>>

Returns

IStreamable<Empty,TResult>

Applies to

AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TState2,TOutput2, TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6, TOutput,TResult>(IStreamable<Empty,TInput>, Expression<Func<TInput, TInnerKey>>, Func<Window<CompoundGroupKey<Empty,TInnerKey>,TInput>, IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput>>, Expression<Func<TInnerKey, TOutput,TResult>>)

Applies multiple aggregates to snapshot windows on the input stream relative to the selected grouping key.

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

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

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

Type Parameters

TInput

TInnerKey

TState1

TOutput1

TState2

TOutput2

TState3

TOutput3

TState4

TOutput4

TState5

TOutput5

TState6

TOutput6

TOutput

TResult

Parameters

source: IStreamable<Empty,TInput>

keySelector: Expression<Func<TInput,TInnerKey>>

aggregate1: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>

aggregate2: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>

aggregate3: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>

aggregate4: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>

aggregate5: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>

aggregate6: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>

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

resultSelector: Expression<Func<TInnerKey,TOutput,TResult>>

Returns

IStreamable<Empty,TResult>

Applies to

AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TState2,TOutput2, TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6, TState7,TOutput7,TOutput,TResult>(IStreamable<Empty,TInput>, Expression<Func<TInput, TInnerKey>>, Func<Window<CompoundGroupKey<Empty,TInnerKey>,TInput>, IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput>>, Expression<Func<TInnerKey,TOutput,TResult>>)

Applies multiple aggregates to snapshot windows on the input stream relative to the selected grouping key.

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

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

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

Type Parameters

TInput

TInnerKey

TState1

TOutput1

TState2

TOutput2

TState3

TOutput3

TState4

TOutput4

TState5

TOutput5

TState6

TOutput6

TState7

TOutput7

TOutput

TResult

Parameters

source: IStreamable<Empty,TInput>

keySelector: Expression<Func<TInput,TInnerKey>>

aggregate1: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>

aggregate2: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>

aggregate3: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>

aggregate4: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>

aggregate5: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>

aggregate6: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>

aggregate7: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>

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

resultSelector: Expression<Func<TInnerKey,TOutput,TResult>>

Returns

IStreamable<Empty,TResult>

Applies to

AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TState2,TOutput2, TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6, TState7,TOutput7,TState8,TOutput8,TOutput,TResult>(IStreamable<Empty, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8, TOutput>>, Expression<Func<TInnerKey,TOutput,TResult>>)

Applies multiple aggregates to snapshot windows on the input stream relative to the selected grouping key.

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

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

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

Type Parameters

TInput

TInnerKey

TState1

TOutput1

TState2

TOutput2

TState3

TOutput3

TState4

TOutput4

TState5

TOutput5

TState6

TOutput6

TState7

TOutput7

TState8

TOutput8

TOutput

TResult

Parameters

source: IStreamable<Empty,TInput>

keySelector: Expression<Func<TInput,TInnerKey>>

aggregate1: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>

aggregate2: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>

aggregate3: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>

aggregate4: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>

aggregate5: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>

aggregate6: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>

aggregate7: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>

aggregate8: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>

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

resultSelector: Expression<Func<TInnerKey,TOutput,TResult>>

Returns

IStreamable<Empty,TResult>

Applies to

AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TState2,TOutput2, TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6, TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TOutput,TResult>(IStreamable<Empty, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8, TOutput9,TOutput>>, Expression<Func<TInnerKey,TOutput,TResult>>)

Applies multiple aggregates to snapshot windows on the input stream relative to the selected grouping key.

public static Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty,TResult> AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TState2,TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TOutput,TResult> (this Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty,TInput> source, System.Linq.Expressions.Expression<Func<TInput,TInnerKey>> keySelector, Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty,TInnerKey>,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState1,TOutput1>> aggregate1, Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty,TInnerKey>,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState2,TOutput2>> aggregate2, Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty,TInnerKey>,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState3,TOutput3>> aggregate3, Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty,TInnerKey>,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState4,TOutput4>> aggregate4, Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty,TInnerKey>,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState5,TOutput5>> aggregate5, Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty,TInnerKey>,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState6,TOutput6>> aggregate6, Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty,TInnerKey>,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState7,TOutput7>> aggregate7, Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty,TInnerKey>,TInput>,Microsoft.StreamProcessing.Aggregates.IAggregate<TInput,TState8,TOutput8>> aggregate8, Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty,TInnerKey>,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, System.Linq.Expressions.Expression<Func<TInnerKey,TOutput,TResult>> resultSelector);

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

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

Type Parameters

TInput

TInnerKey

TState1

TOutput1

TState2

TOutput2

TState3

TOutput3

TState4

TOutput4

TState5

TOutput5

TState6

TOutput6

TState7

TOutput7

TState8

TOutput8

TState9

TOutput9

TOutput

TResult

Parameters

source: IStreamable<Empty,TInput>

keySelector: Expression<Func<TInput,TInnerKey>>

aggregate1: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>

aggregate2: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>

aggregate3: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>

aggregate4: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>

aggregate5: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>

aggregate6: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>

aggregate7: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>

aggregate8: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>

aggregate9: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>

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

resultSelector: Expression<Func<TInnerKey,TOutput,TResult>>

Returns

IStreamable<Empty,TResult>

Applies to

AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TState2,TOutput2, TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6, TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10,TOutput10, TOutput,TResult>(IStreamable<Empty,TInput>, Expression<Func<TInput, TInnerKey>>, Func<Window<CompoundGroupKey<Empty,TInnerKey>,TInput>, IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8, TOutput9,TOutput10,TOutput>>, Expression<Func<TInnerKey,TOutput, TResult>>)

Applies multiple aggregates to snapshot windows on the input stream relative to the selected grouping key.

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

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

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

Type Parameters

TInput

TInnerKey

TState1

TOutput1

TState2

TOutput2

TState3

TOutput3

TState4

TOutput4

TState5

TOutput5

TState6

TOutput6

TState7

TOutput7

TState8

TOutput8

TState9

TOutput9

TState10

TOutput10

TOutput

TResult

Parameters

source: IStreamable<Empty,TInput>

keySelector: Expression<Func<TInput,TInnerKey>>

aggregate1: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>

aggregate2: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>

aggregate3: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>

aggregate4: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>

aggregate5: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>

aggregate6: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>

aggregate7: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>

aggregate8: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>

aggregate9: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>

aggregate10: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>

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

resultSelector: Expression<Func<TInnerKey,TOutput,TResult>>

Returns

IStreamable<Empty,TResult>

Applies to

AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TState2,TOutput2, TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6, TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10,TOutput10, TState11,TOutput11,TOutput,TResult>(IStreamable<Empty,TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8, TOutput9,TOutput10,TOutput11,TOutput>>, Expression<Func<TInnerKey, TOutput,TResult>>)

Applies multiple aggregates to snapshot windows on the input stream relative to the selected grouping key.

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

static member AggregateByKey : Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty, 'Input> * System.Linq.Expressions.Expression<Func<'Input, 'InnerKey>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState1, 'TOutput1>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState2, 'TOutput2>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState3, 'TOutput3>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState4, 'TOutput4>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState5, 'TOutput5>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState6, 'TOutput6>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState7, 'TOutput7>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState8, 'TOutput8>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState9, 'TOutput9>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState10, 'TOutput10>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, '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>> * System.Linq.Expressions.Expression<Func<'InnerKey, 'Output, 'Result>> -> Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty, 'Result>

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

Type Parameters

TInput

TInnerKey

TState1

TOutput1

TState2

TOutput2

TState3

TOutput3

TState4

TOutput4

TState5

TOutput5

TState6

TOutput6

TState7

TOutput7

TState8

TOutput8

TState9

TOutput9

TState10

TOutput10

TState11

TOutput11

TOutput

TResult

Parameters

source: IStreamable<Empty,TInput>

keySelector: Expression<Func<TInput,TInnerKey>>

aggregate1: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>

aggregate2: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>

aggregate3: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>

aggregate4: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>

aggregate5: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>

aggregate6: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>

aggregate7: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>

aggregate8: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>

aggregate9: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>

aggregate10: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>

aggregate11: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>

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

resultSelector: Expression<Func<TInnerKey,TOutput,TResult>>

Returns

IStreamable<Empty,TResult>

Applies to

AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TState2,TOutput2, TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6, TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10,TOutput10, TState11,TOutput11,TState12,TOutput12,TOutput,TResult>(IStreamable<Empty, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState12,TOutput12>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8, TOutput9,TOutput10,TOutput11,TOutput12,TOutput>>, Expression<Func<TInnerKey, TOutput,TResult>>)

Applies multiple aggregates to snapshot windows on the input stream relative to the selected grouping key.

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

static member AggregateByKey : Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty, 'Input> * System.Linq.Expressions.Expression<Func<'Input, 'InnerKey>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState1, 'TOutput1>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState2, 'TOutput2>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState3, 'TOutput3>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState4, 'TOutput4>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState5, 'TOutput5>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState6, 'TOutput6>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState7, 'TOutput7>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState8, 'TOutput8>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState9, 'TOutput9>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState10, 'TOutput10>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState11, 'TOutput11>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, '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>> * System.Linq.Expressions.Expression<Func<'InnerKey, 'Output, 'Result>> -> Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty, 'Result>

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

Type Parameters

TInput

TInnerKey

TState1

TOutput1

TState2

TOutput2

TState3

TOutput3

TState4

TOutput4

TState5

TOutput5

TState6

TOutput6

TState7

TOutput7

TState8

TOutput8

TState9

TOutput9

TState10

TOutput10

TState11

TOutput11

TState12

TOutput12

TOutput

TResult

Parameters

source: IStreamable<Empty,TInput>

keySelector: Expression<Func<TInput,TInnerKey>>

aggregate1: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>

aggregate2: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>

aggregate3: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>

aggregate4: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>

aggregate5: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>

aggregate6: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>

aggregate7: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>

aggregate8: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>

aggregate9: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>

aggregate10: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>

aggregate11: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>

aggregate12: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState12,TOutput12>>

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

resultSelector: Expression<Func<TInnerKey,TOutput,TResult>>

Returns

IStreamable<Empty,TResult>

Applies to

AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TState2,TOutput2, TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6, TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10,TOutput10, TState11,TOutput11,TState12,TOutput12,TState13,TOutput13,TOutput, TResult>(IStreamable<Empty,TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput, TState1,TOutput1>>, Func<Window<CompoundGroupKey<Empty,TInnerKey>, TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState12,TOutput12>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState13,TOutput13>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8, TOutput9,TOutput10,TOutput11,TOutput12,TOutput13,TOutput>>, Expression<Func<TInnerKey, TOutput,TResult>>)

Applies multiple aggregates to snapshot windows on the input stream relative to the selected grouping key.

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

static member AggregateByKey : Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty, 'Input> * System.Linq.Expressions.Expression<Func<'Input, 'InnerKey>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState1, 'TOutput1>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState2, 'TOutput2>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState3, 'TOutput3>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState4, 'TOutput4>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState5, 'TOutput5>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState6, 'TOutput6>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState7, 'TOutput7>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState8, 'TOutput8>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState9, 'TOutput9>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState10, 'TOutput10>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState11, 'TOutput11>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, 'Input>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Input, 'TState12, 'TOutput12>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<Microsoft.StreamProcessing.Empty, 'InnerKey>, '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>> * System.Linq.Expressions.Expression<Func<'InnerKey, 'Output, 'Result>> -> Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty, 'Result>

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

Type Parameters

TInput

TInnerKey

TState1

TOutput1

TState2

TOutput2

TState3

TOutput3

TState4

TOutput4

TState5

TOutput5

TState6

TOutput6

TState7

TOutput7

TState8

TOutput8

TState9

TOutput9

TState10

TOutput10

TState11

TOutput11

TState12

TOutput12

TState13

TOutput13

TOutput

TResult

Parameters

source: IStreamable<Empty,TInput>

keySelector: Expression<Func<TInput,TInnerKey>>

aggregate1: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>

aggregate2: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>

aggregate3: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>

aggregate4: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>

aggregate5: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>

aggregate6: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>

aggregate7: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>

aggregate8: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>

aggregate9: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>

aggregate10: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>

aggregate11: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>

aggregate12: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState12,TOutput12>>

aggregate13: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState13,TOutput13>>

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

resultSelector: Expression<Func<TInnerKey,TOutput,TResult>>

Returns

IStreamable<Empty,TResult>

Applies to

AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TState2,TOutput2, TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6, TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10,TOutput10, TState11,TOutput11,TState12,TOutput12,TState13,TOutput13,TState14, TOutput14,TOutput,TResult>(IStreamable<Empty,TInput>, Expression<Func<TInput, TInnerKey>>, Func<Window<CompoundGroupKey<Empty,TInnerKey>,TInput>, IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState12,TOutput12>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState13,TOutput13>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState14,TOutput14>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8, TOutput9,TOutput10,TOutput11,TOutput12,TOutput13,TOutput14,TOutput>>, Expression<Func<TInnerKey,TOutput,TResult>>)

Applies multiple aggregates to snapshot windows on the input stream relative to the selected grouping key.

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

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

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

Type Parameters

TInput

TInnerKey

TState1

TOutput1

TState2

TOutput2

TState3

TOutput3

TState4

TOutput4

TState5

TOutput5

TState6

TOutput6

TState7

TOutput7

TState8

TOutput8

TState9

TOutput9

TState10

TOutput10

TState11

TOutput11

TState12

TOutput12

TState13

TOutput13

TState14

TOutput14

TOutput

TResult

Parameters

source: IStreamable<Empty,TInput>

keySelector: Expression<Func<TInput,TInnerKey>>

aggregate1: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>

aggregate2: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>

aggregate3: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>

aggregate4: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>

aggregate5: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>

aggregate6: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>

aggregate7: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>

aggregate8: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>

aggregate9: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>

aggregate10: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>

aggregate11: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>

aggregate12: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState12,TOutput12>>

aggregate13: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState13,TOutput13>>

aggregate14: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState14,TOutput14>>

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

resultSelector: Expression<Func<TInnerKey,TOutput,TResult>>

Returns

IStreamable<Empty,TResult>

Applies to

AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TState2,TOutput2, TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6, TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10,TOutput10, TState11,TOutput11,TState12,TOutput12,TState13,TOutput13,TState14, TOutput14,TState15,TOutput15,TOutput,TResult>(IStreamable<Empty, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState12,TOutput12>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState13,TOutput13>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState14,TOutput14>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState15,TOutput15>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8, TOutput9,TOutput10,TOutput11,TOutput12,TOutput13,TOutput14,TOutput15, TOutput>>, Expression<Func<TInnerKey,TOutput,TResult>>)

Applies multiple aggregates to snapshot windows on the input stream relative to the selected grouping key.

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

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

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

Type Parameters

TInput

TInnerKey

TState1

TOutput1

TState2

TOutput2

TState3

TOutput3

TState4

TOutput4

TState5

TOutput5

TState6

TOutput6

TState7

TOutput7

TState8

TOutput8

TState9

TOutput9

TState10

TOutput10

TState11

TOutput11

TState12

TOutput12

TState13

TOutput13

TState14

TOutput14

TState15

TOutput15

TOutput

TResult

Parameters

source: IStreamable<Empty,TInput>

keySelector: Expression<Func<TInput,TInnerKey>>

aggregate1: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>

aggregate2: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>

aggregate3: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>

aggregate4: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>

aggregate5: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>

aggregate6: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>

aggregate7: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>

aggregate8: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>

aggregate9: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>

aggregate10: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>

aggregate11: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>

aggregate12: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState12,TOutput12>>

aggregate13: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState13,TOutput13>>

aggregate14: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState14,TOutput14>>

aggregate15: Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<Empty,TInnerKey>,TInput>,IAggregate<TInput,TState15,TOutput15>>

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

resultSelector: Expression<Func<TInnerKey,TOutput,TResult>>

Returns

IStreamable<Empty,TResult>

Applies to

Share via

Streamable.AggregateByKey Method

Definition

Overloads

AggregateByKey<TInput,TInnerKey,TState1,TOutput1,TOutput>(IStreamable<Empty, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<Empty, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Expression<Func<TInnerKey, TOutput1,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

Type Parameters

Parameters

Returns

Applies to

Additional resources