public static final class PlanUnwrappingReduceGroupOperator.TupleUnwrappingGroupCombinableGroupReducer<IN,OUT,K> extends WrappingFunction<GroupReduceFunction<IN,OUT>> implements GroupReduceFunction<Tuple2<K,IN>,OUT>, GroupCombineFunction<Tuple2<K,IN>,Tuple2<K,IN>>
wrappedFunction
Modifier and Type | Method and Description |
---|---|
void |
combine(Iterable<Tuple2<K,IN>> values,
Collector<Tuple2<K,IN>> out)
The combine method, called (potentially multiple timed) with subgroups of elements.
|
void |
reduce(Iterable<Tuple2<K,IN>> values,
Collector<OUT> out)
The reduce method.
|
String |
toString() |
close, getWrappedFunction, open, setRuntimeContext
getIterationRuntimeContext, getRuntimeContext
public void reduce(Iterable<Tuple2<K,IN>> values, Collector<OUT> out) throws Exception
GroupReduceFunction
reduce
in interface GroupReduceFunction<Tuple2<K,IN>,OUT>
values
- All records that belong to the given input key.out
- The collector to hand results to.Exception
- This method may throw exceptions. Throwing an exception will cause the operation
to fail and may trigger recovery.public void combine(Iterable<Tuple2<K,IN>> values, Collector<Tuple2<K,IN>> out) throws Exception
GroupCombineFunction
combine
in interface GroupCombineFunction<Tuple2<K,IN>,Tuple2<K,IN>>
values
- The elements to be combined.out
- The collector to use to return values from the function.Exception
- The function may throw Exceptions, which will cause the program to cancel,
and may trigger the recovery logic.Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.