Share via


Streamable.Pivot<TKey,TInput,TOutput,TGroupKey,TValue,TAggValue,TState> Method

Definition

public static Microsoft.StreamProcessing.IStreamable<TKey,TOutput> Pivot<TKey,TInput,TOutput,TGroupKey,TValue,TAggValue,TState> (this Microsoft.StreamProcessing.IStreamable<TKey,TInput> inputStreamable, System.Linq.Expressions.Expression<Func<TOutput>> initializer, System.Linq.Expressions.Expression<Func<TInput,TGroupKey>> keySelector, System.Linq.Expressions.Expression<Func<TInput,string>> attributeSelector, System.Linq.Expressions.Expression<Func<TInput,TValue>> valueSelector, Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<TKey,TGroupKey>,TValue>,Microsoft.StreamProcessing.Aggregates.IAggregate<TValue,TState,TAggValue>> aggregate) where TOutput : new();
static member Pivot : Microsoft.StreamProcessing.IStreamable<'Key, 'Input> * System.Linq.Expressions.Expression<Func<'Output>> * System.Linq.Expressions.Expression<Func<'Input, 'GroupKey>> * System.Linq.Expressions.Expression<Func<'Input, string>> * System.Linq.Expressions.Expression<Func<'Input, 'Value>> * Func<Microsoft.StreamProcessing.Window<Microsoft.StreamProcessing.CompoundGroupKey<'Key, 'GroupKey>, 'Value>, Microsoft.StreamProcessing.Aggregates.IAggregate<'Value, 'State, 'AggValue>> -> Microsoft.StreamProcessing.IStreamable<'Key, 'Output (requires 'Output : (new : unit -> 'Output))> (requires 'Output : (new : unit -> 'Output))
<Extension()>
Public Function Pivot(Of TKey, TInput, TOutput, TGroupKey, TValue, TAggValue, TState) (inputStreamable As IStreamable(Of TKey, TInput), initializer As Expression(Of Func(Of TOutput)), keySelector As Expression(Of Func(Of TInput, TGroupKey)), attributeSelector As Expression(Of Func(Of TInput, String)), valueSelector As Expression(Of Func(Of TInput, TValue)), aggregate As Func(Of Window(Of CompoundGroupKey(Of TKey, TGroupKey), TValue), IAggregate(Of TValue, TState, TAggValue))) As IStreamable(Of TKey, TOutput)

Type Parameters

TKey
TInput
TOutput
TGroupKey
TValue
TAggValue
TState

Parameters

inputStreamable
IStreamable<TKey,TInput>
initializer
Expression<Func<TOutput>>
keySelector
Expression<Func<TInput,TGroupKey>>
attributeSelector
Expression<Func<TInput,String>>
valueSelector
Expression<Func<TInput,TValue>>
aggregate
Func<Window<Microsoft.StreamProcessing.CompoundGroupKey<TKey,TGroupKey>,TValue>,IAggregate<TValue,TState,TAggValue>>

Returns

IStreamable<TKey,TOutput>

Applies to