Streamable.GroupApply Method

  • Reference

Definition

Namespace:
Microsoft.StreamProcessing
Assembly:
Microsoft.StreamProcessing.dll

Overloads

GroupApply<TOuterKey,TPayload,TInnerKey,TBind,TResult>(IStreamable<TOuterKey, TPayload>, Expression<Func<TPayload,TInnerKey>>, Func<IStreamable<CompoundGroupKey<TOuterKey, TInnerKey>,TPayload>,IStreamable<CompoundGroupKey<TOuterKey,TInnerKey>, TBind>>, Expression<Func<GroupSelectorInput<TInnerKey>,TBind, TResult>>)

Performs a group and apply operation on the stream.
GroupApply<TOuterKey,TPayload,TInnerKey,TResult>(IStreamable<TOuterKey, TPayload>, Expression<Func<TPayload,TInnerKey>>, Func<IStreamable<CompoundGroupKey<TOuterKey, TInnerKey>,TPayload>,IStreamable<CompoundGroupKey<TOuterKey,TInnerKey>, TResult>>)

Performs a group and apply operation on the stream.

GroupApply<TOuterKey,TPayload,TInnerKey,TBind,TResult>(IStreamable<TOuterKey, TPayload>, Expression<Func<TPayload,TInnerKey>>, Func<IStreamable<CompoundGroupKey<TOuterKey, TInnerKey>,TPayload>,IStreamable<CompoundGroupKey<TOuterKey,TInnerKey>, TBind>>, Expression<Func<GroupSelectorInput<TInnerKey>,TBind, TResult>>)

Performs a group and apply operation on the stream.

public static Microsoft.StreamProcessing.IStreamable<TOuterKey,TResult> GroupApply<TOuterKey,TPayload,TInnerKey,TBind,TResult> (this Microsoft.StreamProcessing.IStreamable<TOuterKey,TPayload> source, System.Linq.Expressions.Expression<Func<TPayload,TInnerKey>> keySelector, Func<Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.CompoundGroupKey<TOuterKey,TInnerKey>,TPayload>,Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.CompoundGroupKey<TOuterKey,TInnerKey>,TBind>> applyFunc, System.Linq.Expressions.Expression<Func<Microsoft.StreamProcessing.GroupSelectorInput<TInnerKey>,TBind,TResult>> resultSelector);
static member GroupApply : Microsoft.StreamProcessing.IStreamable<'OuterKey, 'Payload> * System.Linq.Expressions.Expression<Func<'Payload, 'InnerKey>> * Func<Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.CompoundGroupKey<'OuterKey, 'InnerKey>, 'Payload>, Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.CompoundGroupKey<'OuterKey, 'InnerKey>, 'Bind>> * System.Linq.Expressions.Expression<Func<Microsoft.StreamProcessing.GroupSelectorInput<'InnerKey>, 'Bind, 'Result>> -> Microsoft.StreamProcessing.IStreamable<'OuterKey, 'Result>
<Extension()>
Public Function GroupApply(Of TOuterKey, TPayload, TInnerKey, TBind, TResult) (source As IStreamable(Of TOuterKey, TPayload), keySelector As Expression(Of Func(Of TPayload, TInnerKey)), applyFunc As Func(Of IStreamable(Of CompoundGroupKey(Of TOuterKey, TInnerKey), TPayload), IStreamable(Of CompoundGroupKey(Of TOuterKey, TInnerKey), TBind)), resultSelector As Expression(Of Func(Of GroupSelectorInput(Of TInnerKey), TBind, TResult))) As IStreamable(Of TOuterKey, TResult)

Type Parameters

TOuterKey
TPayload
TInnerKey
TBind
TResult

Parameters

source
IStreamable<TOuterKey,TPayload>
keySelector
Expression<Func<TPayload,TInnerKey>>
applyFunc
Func<IStreamable<Microsoft.StreamProcessing.CompoundGroupKey<TOuterKey,TInnerKey>,TPayload>,IStreamable<Microsoft.StreamProcessing.CompoundGroupKey<TOuterKey,TInnerKey>,TBind>>
resultSelector
Expression<Func<Microsoft.StreamProcessing.GroupSelectorInput<TInnerKey>,TBind,TResult>>

Returns

IStreamable<TOuterKey,TResult>

Applies to

GroupApply<TOuterKey,TPayload,TInnerKey,TResult>(IStreamable<TOuterKey, TPayload>, Expression<Func<TPayload,TInnerKey>>, Func<IStreamable<CompoundGroupKey<TOuterKey, TInnerKey>,TPayload>,IStreamable<CompoundGroupKey<TOuterKey,TInnerKey>, TResult>>)

Performs a group and apply operation on the stream.

public static Microsoft.StreamProcessing.IStreamable<TOuterKey,TResult> GroupApply<TOuterKey,TPayload,TInnerKey,TResult> (this Microsoft.StreamProcessing.IStreamable<TOuterKey,TPayload> source, System.Linq.Expressions.Expression<Func<TPayload,TInnerKey>> keySelector, Func<Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.CompoundGroupKey<TOuterKey,TInnerKey>,TPayload>,Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.CompoundGroupKey<TOuterKey,TInnerKey>,TResult>> applyFunc);
static member GroupApply : Microsoft.StreamProcessing.IStreamable<'OuterKey, 'Payload> * System.Linq.Expressions.Expression<Func<'Payload, 'InnerKey>> * Func<Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.CompoundGroupKey<'OuterKey, 'InnerKey>, 'Payload>, Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.CompoundGroupKey<'OuterKey, 'InnerKey>, 'Result>> -> Microsoft.StreamProcessing.IStreamable<'OuterKey, 'Result>
<Extension()>
Public Function GroupApply(Of TOuterKey, TPayload, TInnerKey, TResult) (source As IStreamable(Of TOuterKey, TPayload), keySelector As Expression(Of Func(Of TPayload, TInnerKey)), applyFunc As Func(Of IStreamable(Of CompoundGroupKey(Of TOuterKey, TInnerKey), TPayload), IStreamable(Of CompoundGroupKey(Of TOuterKey, TInnerKey), TResult))) As IStreamable(Of TOuterKey, TResult)

Type Parameters

TOuterKey
TPayload
TInnerKey
TResult

Parameters

source
IStreamable<TOuterKey,TPayload>
keySelector
Expression<Func<TPayload,TInnerKey>>
applyFunc
Func<IStreamable<Microsoft.StreamProcessing.CompoundGroupKey<TOuterKey,TInnerKey>,TPayload>,IStreamable<Microsoft.StreamProcessing.CompoundGroupKey<TOuterKey,TInnerKey>,TResult>>

Returns

IStreamable<TOuterKey,TResult>

Applies to