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

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TOutput>(IStreamable<TOuterKey, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput>>)	Groups input events by a key selector and applies an aggregate to "snapshot windows" (SI terminology) on each group.
GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TOutput>(IStreamable<TOuterKey,TInput>, Expression<Func<TInput, TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey,TInnerKey>, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput>>)	Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.
GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TOutput>(IStreamable<TOuterKey,TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput>>)	Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.
GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TOutput>(IStreamable<TOuterKey, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput>>)	Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.
GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TOutput>(IStreamable<TOuterKey, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput>>)	Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.
GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TOutput>(IStreamable<TOuterKey,TInput>, Expression<Func<TInput, TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey,TInnerKey>, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput>>)	Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.
GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TOutput>(IStreamable<TOuterKey,TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput>>)	Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.
GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TState8,TOutput8,TOutput>(IStreamable<TOuterKey, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput8,TOutput>>)	Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.
GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TOutput>(IStreamable<TOuterKey, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput8,TOutput9,TOutput>>)	Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.
GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10, TOutput10,TOutput>(IStreamable<TOuterKey,TInput>, Expression<Func<TInput, TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey,TInnerKey>, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput8,TOutput9,TOutput10,TOutput>>)	Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.
GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10, TOutput10,TState11,TOutput11,TOutput>(IStreamable<TOuterKey,TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput8,TOutput9,TOutput10,TOutput11,TOutput>>)	Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.
GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10, TOutput10,TState11,TOutput11,TState12,TOutput12,TOutput>(IStreamable<TOuterKey, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState12,TOutput12>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput8,TOutput9,TOutput10,TOutput11,TOutput12,TOutput>>)	Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.
GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10, TOutput10,TState11,TOutput11,TState12,TOutput12,TState13,TOutput13, TOutput>(IStreamable<TOuterKey,TInput>, Expression<Func<TInput, TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey,TInnerKey>, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState12,TOutput12>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState13,TOutput13>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput8,TOutput9,TOutput10,TOutput11,TOutput12,TOutput13,TOutput>>)	Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.
GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10, TOutput10,TState11,TOutput11,TState12,TOutput12,TState13,TOutput13, TState14,TOutput14,TOutput>(IStreamable<TOuterKey,TInput>, Expression<Func<TInput, TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey,TInnerKey>, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState12,TOutput12>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState13,TOutput13>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState14,TOutput14>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput8,TOutput9,TOutput10,TOutput11,TOutput12,TOutput13,TOutput14, TOutput>>)	Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.
GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10, TOutput10,TState11,TOutput11,TState12,TOutput12,TState13,TOutput13, TState14,TOutput14,TState15,TOutput15,TOutput>(IStreamable<TOuterKey, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState12,TOutput12>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState13,TOutput13>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState14,TOutput14>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState15,TOutput15>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput8,TOutput9,TOutput10,TOutput11,TOutput12,TOutput13,TOutput14, TOutput15,TOutput>>)	Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TOutput>(IStreamable<TOuterKey, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput>>)

Groups input events by a key selector and applies an aggregate to "snapshot windows" (SI terminology) on each group.

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

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

<Extension()>
Public Function GroupAggregate(Of TOuterKey, TInput, TInnerKey, TState1, TOutput1, TOutput) (source As IStreamable(Of TOuterKey, TInput), keySelector As Expression(Of Func(Of TInput, TInnerKey)), aggregate1 As Func(Of Window(Of CompoundGroupKey(Of TOuterKey, TInnerKey), TInput), IAggregate(Of TInput, TState1, TOutput1)), merger As Expression(Of Func(Of GroupSelectorInput(Of TInnerKey), TOutput1, TOutput))) As IStreamable(Of TOuterKey, TOutput)

Type Parameters

TOuterKey

TInput

TInnerKey

TState1

TOutput1

TOutput

Parameters

source: IStreamable<TOuterKey,TInput>

keySelector: Expression<Func<TInput,TInnerKey>>

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

merger: Expression<Func<Microsoft.StreamProcessing.GroupSelectorInput<TInnerKey>,TOutput1,TOutput>>

Returns

IStreamable<TOuterKey,TOutput>

Applies to

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TOutput>(IStreamable<TOuterKey,TInput>, Expression<Func<TInput, TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey,TInnerKey>, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput>>)

Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.

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

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

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

Type Parameters

TOuterKey

TInput

TInnerKey

TState1

TOutput1

TState2

TOutput2

TOutput

Parameters

source: IStreamable<TOuterKey,TInput>

keySelector: Expression<Func<TInput,TInnerKey>>

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

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

merger: Expression<Func<Microsoft.StreamProcessing.GroupSelectorInput<TInnerKey>,TOutput1,TOutput2,TOutput>>

Returns

IStreamable<TOuterKey,TOutput>

Applies to

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TOutput>(IStreamable<TOuterKey,TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput>>)

Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.

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

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

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

Type Parameters

TOuterKey

TInput

TInnerKey

TState1

TOutput1

TState2

TOutput2

TState3

TOutput3

TOutput

Parameters

source: IStreamable<TOuterKey,TInput>

keySelector: Expression<Func<TInput,TInnerKey>>

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

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

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

merger: Expression<Func<Microsoft.StreamProcessing.GroupSelectorInput<TInnerKey>,TOutput1,TOutput2,TOutput3,TOutput>>

Returns

IStreamable<TOuterKey,TOutput>

Applies to

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TOutput>(IStreamable<TOuterKey, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput>>)

Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.

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

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

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

Type Parameters

TOuterKey

TInput

TInnerKey

TState1

TOutput1

TState2

TOutput2

TState3

TOutput3

TState4

TOutput4

TOutput

Parameters

source: IStreamable<TOuterKey,TInput>

keySelector: Expression<Func<TInput,TInnerKey>>

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

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

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

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

merger: Expression<Func<Microsoft.StreamProcessing.GroupSelectorInput<TInnerKey>,TOutput1,TOutput2,TOutput3,TOutput4,TOutput>>

Returns

IStreamable<TOuterKey,TOutput>

Applies to

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

Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.

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

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

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

Type Parameters

TOuterKey

TInput

TInnerKey

TState1

TOutput1

TState2

TOutput2

TState3

TOutput3

TState4

TOutput4

TState5

TOutput5

TOutput

Parameters

source: IStreamable<TOuterKey,TInput>

keySelector: Expression<Func<TInput,TInnerKey>>

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

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

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

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

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

merger: Expression<Func<Microsoft.StreamProcessing.GroupSelectorInput<TInnerKey>,TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput>>

Returns

IStreamable<TOuterKey,TOutput>

Applies to

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

Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.

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

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

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

Type Parameters

TOuterKey

TInput

TInnerKey

TState1

TOutput1

TState2

TOutput2

TState3

TOutput3

TState4

TOutput4

TState5

TOutput5

TState6

TOutput6

TOutput

Parameters

source: IStreamable<TOuterKey,TInput>

keySelector: Expression<Func<TInput,TInnerKey>>

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

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

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

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

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

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

merger: Expression<Func<Microsoft.StreamProcessing.GroupSelectorInput<TInnerKey>,TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput>>

Returns

IStreamable<TOuterKey,TOutput>

Applies to

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

Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.

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

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

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

Type Parameters

TOuterKey

TInput

TInnerKey

TState1

TOutput1

TState2

TOutput2

TState3

TOutput3

TState4

TOutput4

TState5

TOutput5

TState6

TOutput6

TState7

TOutput7

TOutput

Parameters

source: IStreamable<TOuterKey,TInput>

keySelector: Expression<Func<TInput,TInnerKey>>

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

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

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

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

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

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

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

merger: Expression<Func<Microsoft.StreamProcessing.GroupSelectorInput<TInnerKey>,TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput>>

Returns

IStreamable<TOuterKey,TOutput>

Applies to

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

Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.

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

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

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

Type Parameters

TOuterKey

TInput

TInnerKey

TState1

TOutput1

TState2

TOutput2

TState3

TOutput3

TState4

TOutput4

TState5

TOutput5

TState6

TOutput6

TState7

TOutput7

TState8

TOutput8

TOutput

Parameters

source: IStreamable<TOuterKey,TInput>

keySelector: Expression<Func<TInput,TInnerKey>>

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

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

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

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

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

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

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

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

merger: Expression<Func<Microsoft.StreamProcessing.GroupSelectorInput<TInnerKey>,TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8,TOutput>>

Returns

IStreamable<TOuterKey,TOutput>

Applies to

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

Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.

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

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

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

Type Parameters

TOuterKey

TInput

TInnerKey

TState1

TOutput1

TState2

TOutput2

TState3

TOutput3

TState4

TOutput4

TState5

TOutput5

TState6

TOutput6

TState7

TOutput7

TState8

TOutput8

TState9

TOutput9

TOutput

Parameters

source: IStreamable<TOuterKey,TInput>

keySelector: Expression<Func<TInput,TInnerKey>>

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

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

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

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

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

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

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

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

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

merger: Expression<Func<Microsoft.StreamProcessing.GroupSelectorInput<TInnerKey>,TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8,TOutput9,TOutput>>

Returns

IStreamable<TOuterKey,TOutput>

Applies to

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

Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.

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

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

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

Type Parameters

TOuterKey

TInput

TInnerKey

TState1

TOutput1

TState2

TOutput2

TState3

TOutput3

TState4

TOutput4

TState5

TOutput5

TState6

TOutput6

TState7

TOutput7

TState8

TOutput8

TState9

TOutput9

TState10

TOutput10

TOutput

Parameters

source: IStreamable<TOuterKey,TInput>

keySelector: Expression<Func<TInput,TInnerKey>>

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

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

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

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

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

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

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

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

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

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

merger: Expression<Func<Microsoft.StreamProcessing.GroupSelectorInput<TInnerKey>,TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8,TOutput9,TOutput10,TOutput>>

Returns

IStreamable<TOuterKey,TOutput>

Applies to

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

Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.

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

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

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

Type Parameters

TOuterKey

TInput

TInnerKey

TState1

TOutput1

TState2

TOutput2

TState3

TOutput3

TState4

TOutput4

TState5

TOutput5

TState6

TOutput6

TState7

TOutput7

TState8

TOutput8

TState9

TOutput9

TState10

TOutput10

TState11

TOutput11

TOutput

Parameters

source: IStreamable<TOuterKey,TInput>

keySelector: Expression<Func<TInput,TInnerKey>>

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

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

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

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

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

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

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

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

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

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

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

merger: Expression<Func<Microsoft.StreamProcessing.GroupSelectorInput<TInnerKey>,TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8,TOutput9,TOutput10,TOutput11,TOutput>>

Returns

IStreamable<TOuterKey,TOutput>

Applies to

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

Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.

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

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

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

Type Parameters

TOuterKey

TInput

TInnerKey

TState1

TOutput1

TState2

TOutput2

TState3

TOutput3

TState4

TOutput4

TState5

TOutput5

TState6

TOutput6

TState7

TOutput7

TState8

TOutput8

TState9

TOutput9

TState10

TOutput10

TState11

TOutput11

TState12

TOutput12

TOutput

Parameters

source: IStreamable<TOuterKey,TInput>

keySelector: Expression<Func<TInput,TInnerKey>>

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

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

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

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

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

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

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

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

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

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

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

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

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

Returns

IStreamable<TOuterKey,TOutput>

Applies to

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

Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.

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

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

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

Type Parameters

TOuterKey

TInput

TInnerKey

TState1

TOutput1

TState2

TOutput2

TState3

TOutput3

TState4

TOutput4

TState5

TOutput5

TState6

TOutput6

TState7

TOutput7

TState8

TOutput8

TState9

TOutput9

TState10

TOutput10

TState11

TOutput11

TState12

TOutput12

TState13

TOutput13

TOutput

Parameters

source: IStreamable<TOuterKey,TInput>

keySelector: Expression<Func<TInput,TInnerKey>>

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Returns

IStreamable<TOuterKey,TOutput>

Applies to

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

Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.

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

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

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

Type Parameters

TOuterKey

TInput

TInnerKey

TState1

TOutput1

TState2

TOutput2

TState3

TOutput3

TState4

TOutput4

TState5

TOutput5

TState6

TOutput6

TState7

TOutput7

TState8

TOutput8

TState9

TOutput9

TState10

TOutput10

TState11

TOutput11

TState12

TOutput12

TState13

TOutput13

TState14

TOutput14

TOutput

Parameters

source: IStreamable<TOuterKey,TInput>

keySelector: Expression<Func<TInput,TInnerKey>>

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Returns

IStreamable<TOuterKey,TOutput>

Applies to

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

Groups input events by a key selector and applies multiple aggregates to "snapshot windows" (SI terminology) on each group.

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

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

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

Type Parameters

TOuterKey

TInput

TInnerKey

TState1

TOutput1

TState2

TOutput2

TState3

TOutput3

TState4

TOutput4

TState5

TOutput5

TState6

TOutput6

TState7

TOutput7

TState8

TOutput8

TState9

TOutput9

TState10

TOutput10

TState11

TOutput11

TState12

TOutput12

TState13

TOutput13

TState14

TOutput14

TState15

TOutput15

TOutput

Parameters

source: IStreamable<TOuterKey,TInput>

keySelector: Expression<Func<TInput,TInnerKey>>

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Returns

IStreamable<TOuterKey,TOutput>

Applies to

Streamable.GroupAggregate Method

Definition

Overloads

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TOutput>(IStreamable<TOuterKey, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput>>)

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