Streamable.SelectMany Method

Definition

Namespace:

Microsoft.StreamProcessing

Assembly:

Microsoft.StreamProcessing.dll

Overloads

SelectMany<TKey,TLeft,TRight,TResult>(IStreamable<TKey,TLeft>, Func<Empty,IStreamable<TKey,TRight>>, Expression<Func<TLeft,TRight,TResult>>)	This select many is used for joins derived from the comprehension syntax as well as non-empty reducers in Group and Apply
SelectMany<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<Int64,TPayload,IEnumerable<TResult>>>)	This select many is used for generating many payloads out of one
SelectMany<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,IEnumerable<TResult>>>)	This select many is used for generating many payloads out of one
SelectMany<TOuterKey,TInnerKey,TPayload,TResult,TBind,TOutput>(IMapDefinition<TOuterKey, TPayload,TPayload,TInnerKey,TResult>, Func<IStreamable<CompoundGroupKey<TOuterKey, TInnerKey>,TResult>,IStreamable<CompoundGroupKey<TOuterKey,TInnerKey>, TBind>>, Expression<Func<GroupSelectorInput<TInnerKey>,TBind, TOutput>>)	This is here to make the comprehension syntax happy. Consider using GroupApply instead.

SelectMany<TKey,TLeft,TRight,TResult>(IStreamable<TKey,TLeft>, Func<Empty,IStreamable<TKey,TRight>>, Expression<Func<TLeft,TRight,TResult>>)

This select many is used for joins derived from the comprehension syntax as well as non-empty reducers in Group and Apply

public static Microsoft.StreamProcessing.IStreamable<TKey,TResult> SelectMany<TKey,TLeft,TRight,TResult> (this Microsoft.StreamProcessing.IStreamable<TKey,TLeft> left, Func<Microsoft.StreamProcessing.Empty,Microsoft.StreamProcessing.IStreamable<TKey,TRight>> right, System.Linq.Expressions.Expression<Func<TLeft,TRight,TResult>> resultSelector);

static member SelectMany : Microsoft.StreamProcessing.IStreamable<'Key, 'Left> * Func<Microsoft.StreamProcessing.Empty, Microsoft.StreamProcessing.IStreamable<'Key, 'Right>> * System.Linq.Expressions.Expression<Func<'Left, 'Right, 'Result>> -> Microsoft.StreamProcessing.IStreamable<'Key, 'Result>

<Extension()>
Public Function SelectMany(Of TKey, TLeft, TRight, TResult) (left As IStreamable(Of TKey, TLeft), right As Func(Of Empty, IStreamable(Of TKey, TRight)), resultSelector As Expression(Of Func(Of TLeft, TRight, TResult))) As IStreamable(Of TKey, TResult)

Type Parameters

TKey

TLeft

TRight

TResult

Parameters

left

IStreamable<TKey,TLeft>

right

Func<Empty,IStreamable<TKey,TRight>>

resultSelector

Expression<Func<TLeft,TRight,TResult>>

Returns

IStreamable<TKey,TResult>

SelectMany<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<Int64,TPayload,IEnumerable<TResult>>>)

This select many is used for generating many payloads out of one

public static Microsoft.StreamProcessing.IStreamable<TKey,TResult> SelectMany<TKey,TPayload,TResult> (this Microsoft.StreamProcessing.IStreamable<TKey,TPayload> source, System.Linq.Expressions.Expression<Func<long,TPayload,System.Collections.Generic.IEnumerable<TResult>>> selector);

static member SelectMany : Microsoft.StreamProcessing.IStreamable<'Key, 'Payload> * System.Linq.Expressions.Expression<Func<int64, 'Payload, seq<'Result>>> -> Microsoft.StreamProcessing.IStreamable<'Key, 'Result>

<Extension()>
Public Function SelectMany(Of TKey, TPayload, TResult) (source As IStreamable(Of TKey, TPayload), selector As Expression(Of Func(Of Long, TPayload, IEnumerable(Of TResult)))) As IStreamable(Of TKey, TResult)

Type Parameters

TKey

TPayload

TResult

Parameters

source

IStreamable<TKey,TPayload>

selector

Expression<Func<Int64,TPayload,IEnumerable<TResult>>>

Returns

IStreamable<TKey,TResult>

SelectMany<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,IEnumerable<TResult>>>)

This select many is used for generating many payloads out of one

public static Microsoft.StreamProcessing.IStreamable<TKey,TResult> SelectMany<TKey,TPayload,TResult> (this Microsoft.StreamProcessing.IStreamable<TKey,TPayload> source, System.Linq.Expressions.Expression<Func<TPayload,System.Collections.Generic.IEnumerable<TResult>>> selector);

static member SelectMany : Microsoft.StreamProcessing.IStreamable<'Key, 'Payload> * System.Linq.Expressions.Expression<Func<'Payload, seq<'Result>>> -> Microsoft.StreamProcessing.IStreamable<'Key, 'Result>

<Extension()>
Public Function SelectMany(Of TKey, TPayload, TResult) (source As IStreamable(Of TKey, TPayload), selector As Expression(Of Func(Of TPayload, IEnumerable(Of TResult)))) As IStreamable(Of TKey, TResult)

Type Parameters

TKey

TPayload

TResult

Parameters

source

IStreamable<TKey,TPayload>

selector

Expression<Func<TPayload,IEnumerable<TResult>>>

Returns

IStreamable<TKey,TResult>

SelectMany<TOuterKey,TInnerKey,TPayload,TResult,TBind,TOutput>(IMapDefinition<TOuterKey, TPayload,TPayload,TInnerKey,TResult>, Func<IStreamable<CompoundGroupKey<TOuterKey, TInnerKey>,TResult>,IStreamable<CompoundGroupKey<TOuterKey,TInnerKey>, TBind>>, Expression<Func<GroupSelectorInput<TInnerKey>,TBind, TOutput>>)

This is here to make the comprehension syntax happy. Consider using GroupApply instead.

public static Microsoft.StreamProcessing.IStreamable<TOuterKey,TOutput> SelectMany<TOuterKey,TInnerKey,TPayload,TResult,TBind,TOutput> (this Microsoft.StreamProcessing.IMapDefinition<TOuterKey,TPayload,TPayload,TInnerKey,TResult> groupDefinition, Func<Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.CompoundGroupKey<TOuterKey,TInnerKey>,TResult>,Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.CompoundGroupKey<TOuterKey,TInnerKey>,TBind>> apply, System.Linq.Expressions.Expression<Func<Microsoft.StreamProcessing.GroupSelectorInput<TInnerKey>,TBind,TOutput>> resultSelector);

static member SelectMany : Microsoft.StreamProcessing.IMapDefinition<'OuterKey, 'Payload, 'Payload, 'InnerKey, 'Result> * Func<Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.CompoundGroupKey<'OuterKey, 'InnerKey>, 'Result>, Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.CompoundGroupKey<'OuterKey, 'InnerKey>, 'Bind>> * System.Linq.Expressions.Expression<Func<Microsoft.StreamProcessing.GroupSelectorInput<'InnerKey>, 'Bind, 'Output>> -> Microsoft.StreamProcessing.IStreamable<'OuterKey, 'Output>

<Extension()>
Public Function SelectMany(Of TOuterKey, TInnerKey, TPayload, TResult, TBind, TOutput) (groupDefinition As IMapDefinition(Of TOuterKey, TPayload, TPayload, TInnerKey, TResult), apply As Func(Of IStreamable(Of CompoundGroupKey(Of TOuterKey, TInnerKey), TResult), IStreamable(Of CompoundGroupKey(Of TOuterKey, TInnerKey), TBind)), resultSelector As Expression(Of Func(Of GroupSelectorInput(Of TInnerKey), TBind, TOutput))) As IStreamable(Of TOuterKey, TOutput)

Type Parameters

TOuterKey

TInnerKey

TPayload

TResult

TBind

TOutput

Parameters

groupDefinition

IMapDefinition<TOuterKey,TPayload,TPayload,TInnerKey,TResult>

apply

Func<IStreamable<Microsoft.StreamProcessing.CompoundGroupKey<TOuterKey,TInnerKey>,TResult>,IStreamable<Microsoft.StreamProcessing.CompoundGroupKey<TOuterKey,TInnerKey>,TBind>>

resultSelector

Expression<Func<Microsoft.StreamProcessing.GroupSelectorInput<TInnerKey>,TBind,TOutput>>

Returns

IStreamable<TOuterKey,TOutput>