Streamable.SelectByKey Method

Definition

Overloads

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

Performs a project over a streamable, relative to the grouping key.

SelectByKey<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<TKey,TPayload,TResult>>)

Performs a project over a streamable, relative to the grouping key.

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

Performs a project over a streamable, relative to the grouping key.

public static Microsoft.StreamProcessing.IStreamable<TKey,TResult> SelectByKey<TKey,TPayload,TResult> (this Microsoft.StreamProcessing.IStreamable<TKey,TPayload> source, System.Linq.Expressions.Expression<Func<long,TKey,TPayload,TResult>> selector);
static member SelectByKey : Microsoft.StreamProcessing.IStreamable<'Key, 'Payload> * System.Linq.Expressions.Expression<Func<int64, 'Key, 'Payload, 'Result>> -> Microsoft.StreamProcessing.IStreamable<'Key, 'Result>
<Extension()>
Public Function SelectByKey(Of TKey, TPayload, TResult) (source As IStreamable(Of TKey, TPayload), selector As Expression(Of Func(Of Long, TKey, TPayload, TResult))) As IStreamable(Of TKey, TResult)

Type Parameters

TKey
TPayload
TResult

Parameters

source
IStreamable<TKey,TPayload>

Source streamable for the operation.

selector
Expression<Func<Int64,TKey,TPayload,TResult>>

Expression over StartTime, Key, and Payload, that returns the new Payload.

Returns

IStreamable<TKey,TResult>

Applies to

SelectByKey<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<TKey,TPayload,TResult>>)

Performs a project over a streamable, relative to the grouping key.

public static Microsoft.StreamProcessing.IStreamable<TKey,TResult> SelectByKey<TKey,TPayload,TResult> (this Microsoft.StreamProcessing.IStreamable<TKey,TPayload> source, System.Linq.Expressions.Expression<Func<TKey,TPayload,TResult>> selector);
static member SelectByKey : Microsoft.StreamProcessing.IStreamable<'Key, 'Payload> * System.Linq.Expressions.Expression<Func<'Key, 'Payload, 'Result>> -> Microsoft.StreamProcessing.IStreamable<'Key, 'Result>
<Extension()>
Public Function SelectByKey(Of TKey, TPayload, TResult) (source As IStreamable(Of TKey, TPayload), selector As Expression(Of Func(Of TKey, TPayload, TResult))) As IStreamable(Of TKey, TResult)

Type Parameters

TKey
TPayload
TResult

Parameters

source
IStreamable<TKey,TPayload>

Source streamable for the operation.

selector
Expression<Func<TKey,TPayload,TResult>>

Expression over Key and Payload, that returns the new Payload.

Returns

IStreamable<TKey,TResult>

Applies to