 | JobBuilderGroupAggregateTKey, TValue(IOperationInput, FuncTKey, TValue, TValue, TaskContext, TValue, Type, RecordReuseMode) Method |
Groups the input records by key, then aggregates their values using the specified accumulator task function.
Namespace: Ookii.Jumbo.Jet.Jobs.BuilderAssembly: Ookii.Jumbo.Jet (in Ookii.Jumbo.Jet.dll) Version: 0.3.0+dc1307f20e065bb638e0b73a34cd216f57e486f1
Syntaxpublic TwoStepOperation GroupAggregate<TKey, TValue>(
IOperationInput input,
Func<TKey, TValue, TValue, TaskContext, TValue> accumulator,
Type? keyComparerType = null,
RecordReuseMode recordReuse = RecordReuseMode.Default
)
where TKey : Object, IComparable<TKey>
Public Function GroupAggregate(Of TKey As {Object, IComparable(Of TKey)}, TValue) (
input As IOperationInput,
accumulator As Func(Of TKey, TValue, TValue, TaskContext, TValue),
Optional keyComparerType As Type = Nothing,
Optional recordReuse As RecordReuseMode = RecordReuseMode.Default
) As TwoStepOperation
public:
generic<typename TKey, typename TValue>
where TKey : Object, IComparable<TKey>
TwoStepOperation^ GroupAggregate(
IOperationInput^ input,
Func<TKey, TValue, TValue, TaskContext^, TValue>^ accumulator,
Type^ keyComparerType = nullptr,
RecordReuseMode recordReuse = RecordReuseMode::Default
)
member GroupAggregate :
input : IOperationInput *
accumulator : Func<'TKey, 'TValue, 'TValue, TaskContext, 'TValue> *
?keyComparerType : Type *
?recordReuse : RecordReuseMode
(* Defaults:
let _keyComparerType = defaultArg keyComparerType null
let _recordReuse = defaultArg recordReuse RecordReuseMode.Default
*)
-> TwoStepOperation when 'TKey : Object and IComparable<'TKey>
Parameters
- input IOperationInput
- The input.
- accumulator FuncTKey, TValue, TValue, TaskContext, TValue
- The accumulator function to use to create the task.
- keyComparerType Type (Optional)
- Type of the IEqualityComparerT to use to compare the aggregation keys,
or to use Default. May be a generic type definition with one type parameter, which will be set to the key type.
- recordReuse RecordReuseMode (Optional)
- The record reuse mode.
Type Parameters
- TKey
- The type of the key.
- TValue
- The type of the value.
Return Value
TwoStepOperationA
TwoStepOperation instance that can be used to further customize the operation.
Remarks
This method generates a class implementing AccumulatorTaskTKey, TValue which calls the target method of the accumulator delegate
from the Accumulate(TKey, TValue, TValue) method.
Note |
---|
The task method will be called from a completely different process than the one that is using JobBuilder, so it should not really
on any external state.
|
If recordReuse is Default and the target method has the AllowRecordReuseAttribute attribute applied to it,
that attribute will be copied to the task class. If the target method has the ProcessAllInputPartitionsAttribute attribute applied to it,
that attribute will be copied to the task class.
The target method must be a public static method.
See Also