Class RichGroupCombineFunction<IN,OUT>
- java.lang.Object
-
- org.apache.flink.api.common.functions.AbstractRichFunction
-
- org.apache.flink.api.common.functions.RichGroupCombineFunction<IN,OUT>
-
- Type Parameters:
IN
- The data type of the elements to be combined.OUT
- The resulting data type of the elements to be combined.
- All Implemented Interfaces:
Serializable
,Function
,GroupCombineFunction<IN,OUT>
,RichFunction
@Public public abstract class RichGroupCombineFunction<IN,OUT> extends AbstractRichFunction implements GroupCombineFunction<IN,OUT>
Rich variant of theGroupCombineFunction
. As aRichFunction
, it gives access to theRuntimeContext
and provides setup and teardown methods:RichFunction.open(OpenContext)
andRichFunction.close()
.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description RichGroupCombineFunction()
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description abstract void
combine(Iterable<IN> values, Collector<OUT> out)
The combine method, called (potentially multiple timed) with subgroups of elements.-
Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction
close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
-
-
-
-
Method Detail
-
combine
public abstract void combine(Iterable<IN> values, Collector<OUT> out) throws Exception
Description copied from interface:GroupCombineFunction
The combine method, called (potentially multiple timed) with subgroups of elements.- Specified by:
combine
in interfaceGroupCombineFunction<IN,OUT>
- Parameters:
values
- The elements to be combined.out
- The collector to use to return values from the function.- Throws:
Exception
- The function may throw Exceptions, which will cause the program to cancel, and may trigger the recovery logic.
-
-