 | JobBuilderReduceTKey, TValue, TOutput(IOperationInput, ActionTKey, IEnumerableTValue, RecordWriterTOutput, TaskContext, RecordReuseMode) Method |
Runs a reduce function on each key in the specified input.
Namespace: Ookii.Jumbo.Jet.Jobs.BuilderAssembly: Ookii.Jumbo.Jet (in Ookii.Jumbo.Jet.dll) Version: 0.3.0+dc1307f20e065bb638e0b73a34cd216f57e486f1
Syntaxpublic StageOperation Reduce<TKey, TValue, TOutput>(
IOperationInput input,
Action<TKey, IEnumerable<TValue>, RecordWriter<TOutput>, TaskContext> reducer,
RecordReuseMode recordReuse = RecordReuseMode.Default
)
where TKey : Object, IComparable<TKey>
Public Function Reduce(Of TKey As {Object, IComparable(Of TKey)}, TValue, TOutput) (
input As IOperationInput,
reducer As Action(Of TKey, IEnumerable(Of TValue), RecordWriter(Of TOutput), TaskContext),
Optional recordReuse As RecordReuseMode = RecordReuseMode.Default
) As StageOperation
public:
generic<typename TKey, typename TValue, typename TOutput>
where TKey : Object, IComparable<TKey>
StageOperation^ Reduce(
IOperationInput^ input,
Action<TKey, IEnumerable<TValue>^, RecordWriter<TOutput>^, TaskContext^>^ reducer,
RecordReuseMode recordReuse = RecordReuseMode::Default
)
member Reduce :
input : IOperationInput *
reducer : Action<'TKey, IEnumerable<'TValue>, RecordWriter<'TOutput>, TaskContext> *
?recordReuse : RecordReuseMode
(* Defaults:
let _recordReuse = defaultArg recordReuse RecordReuseMode.Default
*)
-> StageOperation when 'TKey : Object and IComparable<'TKey>
Parameters
- input IOperationInput
- The input.
- reducer ActionTKey, IEnumerableTValue, RecordWriterTOutput, TaskContext
- The reducer function.
- recordReuse RecordReuseMode (Optional)
- The record reuse mode.
Type Parameters
- TKey
- The type of the keys.
- TValue
- The type of the values.
- TOutput
- The type of the output records.
Return Value
StageOperationA
StageOperation instance that can be used to further customize the operation.
Remarks
See Also