Uses of Interface
org.apache.flink.api.common.functions.GroupCombineFunction

Packages that use GroupCombineFunction

Package	Description
org.apache.flink.api.common.functions
org.apache.flink.api.common.operators.base
org.apache.flink.api.java
org.apache.flink.api.java.functions
org.apache.flink.api.java.operators
org.apache.flink.api.java.operators.translation
org.apache.flink.api.java.typeutils
org.apache.flink.hadoopcompatibility.mapred
org.apache.flink.runtime.operators
org.apache.flink.runtime.operators.sort

Uses of GroupCombineFunction in org.apache.flink.api.common.functions

Classes in org.apache.flink.api.common.functions that implement GroupCombineFunction

Modifier and Type	Class and Description
class	RichGroupCombineFunction<IN,OUT> Rich variant of the GroupCombineFunction.

Uses of GroupCombineFunction in org.apache.flink.api.common.operators.base

Classes in org.apache.flink.api.common.operators.base with type parameters of type GroupCombineFunction

Modifier and Type	Class and Description
class	GroupCombineOperatorBase<IN,OUT,FT extends GroupCombineFunction<IN,OUT>> Base operator for the combineGroup transformation.

Uses of GroupCombineFunction in org.apache.flink.api.java

Methods in org.apache.flink.api.java with parameters of type GroupCombineFunction

Modifier and Type	Method and Description
<R> GroupCombineOperator<T,R>	DataSet.combineGroup(GroupCombineFunction<T,R> combiner) Deprecated. Applies a GroupCombineFunction on a non-grouped DataSet.

Uses of GroupCombineFunction in org.apache.flink.api.java.functions

Classes in org.apache.flink.api.java.functions that implement GroupCombineFunction

Modifier and Type	Class and Description
class	FirstReducer<T> Reducer that only emits the first N elements in a group.

Uses of GroupCombineFunction in org.apache.flink.api.java.operators

Methods in org.apache.flink.api.java.operators that return GroupCombineFunction

Modifier and Type	Method and Description
protected GroupCombineFunction<IN,OUT>	GroupCombineOperator.getFunction() Deprecated.

Methods in org.apache.flink.api.java.operators with parameters of type GroupCombineFunction

Modifier and Type	Method and Description
<R> GroupCombineOperator<T,R>	SortedGrouping.combineGroup(GroupCombineFunction<T,R> combiner) Deprecated. Applies a GroupCombineFunction on a grouped DataSet.
<R> GroupCombineOperator<T,R>	UnsortedGrouping.combineGroup(GroupCombineFunction<T,R> combiner) Deprecated. Applies a GroupCombineFunction on a grouped DataSet.

Constructors in org.apache.flink.api.java.operators with parameters of type GroupCombineFunction

Constructor and Description
GroupCombineOperator(DataSet<IN> input, TypeInformation<OUT> resultType, GroupCombineFunction<IN,OUT> function, String defaultName) Deprecated. Constructor for a non-grouped reduce (all reduce).
GroupCombineOperator(Grouping<IN> input, TypeInformation<OUT> resultType, GroupCombineFunction<IN,OUT> function, String defaultName) Deprecated. Constructor for a grouped reduce.

Uses of GroupCombineFunction in org.apache.flink.api.java.operators.translation

Classes in org.apache.flink.api.java.operators.translation that implement GroupCombineFunction

Modifier and Type	Class and Description
class	CombineToGroupCombineWrapper<IN,OUT,F extends CombineFunction<IN,IN> & GroupReduceFunction<IN,OUT>> A wrapper the wraps a function that implements both CombineFunction and GroupReduceFunction interfaces and makes it look like a function that implements GroupCombineFunction and GroupReduceFunction to the runtime.
class	RichCombineToGroupCombineWrapper<IN,OUT,F extends RichGroupReduceFunction<IN,OUT> & CombineFunction<IN,IN>> A wrapper the wraps a function that implements both CombineFunction and GroupReduceFunction interfaces and makes it look like a function that implements GroupCombineFunction and GroupReduceFunction to the runtime.

Constructors in org.apache.flink.api.java.operators.translation with parameters of type GroupCombineFunction

Constructor and Description
PlanUnwrappingGroupCombineOperator(GroupCombineFunction<IN,OUT> udf, Keys.SelectorFunctionKeys<IN,K> key, String name, TypeInformation<OUT> outType, TypeInformation<Tuple2<K,IN>> typeInfoWithKey)
PlanUnwrappingSortedGroupCombineOperator(GroupCombineFunction<IN,OUT> udf, Keys.SelectorFunctionKeys<IN,K1> groupingKey, Keys.SelectorFunctionKeys<IN,K2> sortingKey, String name, TypeInformation<OUT> outType, TypeInformation<Tuple3<K1,K2,IN>> typeInfoWithKey)

Uses of GroupCombineFunction in org.apache.flink.api.java.typeutils

Methods in org.apache.flink.api.java.typeutils with parameters of type GroupCombineFunction

Modifier and Type	Method and Description
static <IN,OUT> TypeInformation<OUT>	TypeExtractor.getGroupCombineReturnTypes(GroupCombineFunction<IN,OUT> combineInterface, TypeInformation<IN> inType)
static <IN,OUT> TypeInformation<OUT>	TypeExtractor.getGroupCombineReturnTypes(GroupCombineFunction<IN,OUT> combineInterface, TypeInformation<IN> inType, String functionName, boolean allowMissing)

Uses of GroupCombineFunction in org.apache.flink.hadoopcompatibility.mapred

Classes in org.apache.flink.hadoopcompatibility.mapred that implement GroupCombineFunction

Modifier and Type	Class and Description
class	HadoopReduceCombineFunction<KEYIN,VALUEIN,KEYOUT,VALUEOUT> This wrapper maps a Hadoop Reducer and Combiner (mapred API) to a combinable Flink GroupReduceFunction.

Uses of GroupCombineFunction in org.apache.flink.runtime.operators

Methods in org.apache.flink.runtime.operators that return types with arguments of type GroupCombineFunction

Modifier and Type	Method and Description
Class<GroupCombineFunction<IN,OUT>>	AllGroupCombineDriver.getStubType()
Class<GroupCombineFunction<IN,OUT>>	GroupReduceCombineDriver.getStubType()

Method parameters in org.apache.flink.runtime.operators with type arguments of type GroupCombineFunction

Modifier and Type	Method and Description
void	AllGroupCombineDriver.setup(TaskContext<GroupCombineFunction<IN,OUT>,OUT> context)
void	GroupReduceCombineDriver.setup(TaskContext<GroupCombineFunction<IN,OUT>,OUT> context)

Uses of GroupCombineFunction in org.apache.flink.runtime.operators.sort

Methods in org.apache.flink.runtime.operators.sort with parameters of type GroupCombineFunction

Modifier and Type	Method and Description
ExternalSorterBuilder<T>	ExternalSorterBuilder.withCombiner(GroupCombineFunction<T,T> combineFunction)
ExternalSorterBuilder<T>	ExternalSorterBuilder.withCombiner(GroupCombineFunction<T,T> combineFunction, Configuration udfConfig)