org.apache.flink.api.common.operators.base

Class GroupCombineOperatorBase<IN,OUT,FT extends GroupCombineFunction<IN,OUT>>

java.lang.Object

org.apache.flink.api.common.operators.Operator<OUT>

org.apache.flink.api.common.operators.AbstractUdfOperator<OUT,FT>

org.apache.flink.api.common.operators.SingleInputOperator<IN,OUT,FT>

org.apache.flink.api.common.operators.base.GroupCombineOperatorBase<IN,OUT,FT>

All Implemented Interfaces:

Visitable<Operator<?>>

Direct Known Subclasses:

PlanUnwrappingGroupCombineOperator, PlanUnwrappingSortedGroupCombineOperator

@Internal
public class GroupCombineOperatorBase<IN,OUT,FT extends GroupCombineFunction<IN,OUT>>
extends SingleInputOperator<IN,OUT,FT>

Base operator for the combineGroup transformation. It receives the UDF GroupCombineFunction as an input. This class is later processed by the compiler to generate the plan.

See Also:

CombineFunction

Field Summary

Fields inherited from class org.apache.flink.api.common.operators.SingleInputOperator

input

Fields inherited from class org.apache.flink.api.common.operators.AbstractUdfOperator

broadcastInputs, userFunction

Fields inherited from class org.apache.flink.api.common.operators.Operator

compilerHints, name, operatorInfo, parameters

Constructor Summary

Constructors

Constructor and Description
GroupCombineOperatorBase(FT udf, UnaryOperatorInformation<IN,OUT> operatorInfo, int[] keyPositions, String name)

Method Summary

Modifier and Type	Method and Description
protected List<OUT>	executeOnCollections(List<IN> inputData, RuntimeContext ctx, ExecutionConfig executionConfig)
Ordering	getGroupOrder() Gets the order of elements within a reduce group.
void	setGroupOrder(Ordering order) Sets the order of the elements within a reduce group.

Methods inherited from class org.apache.flink.api.common.operators.SingleInputOperator

accept, addInput, addInput, clearInputs, getInput, getKeyColumns, getNumberOfInputs, getOperatorInfo, getSemanticProperties, setInput, setInput, setInputs, setSemanticProperties

Methods inherited from class org.apache.flink.api.common.operators.AbstractUdfOperator

asArray, emptyClassArray, getBroadcastInputs, getUserCodeWrapper, setBroadcastVariable, setBroadcastVariables

Methods inherited from class org.apache.flink.api.common.operators.Operator

createUnionCascade, createUnionCascade, createUnionCascade, getCompilerHints, getMinResources, getName, getParallelism, getParameters, getPreferredResources, setName, setParallelism, setParameter, setParameter, setParameter, setResources, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

GroupCombineOperatorBase

public GroupCombineOperatorBase(FT udf,
                                UnaryOperatorInformation<IN,OUT> operatorInfo,
                                int[] keyPositions,
                                String name)

Method Detail

setGroupOrder

public void setGroupOrder(Ordering order)

Sets the order of the elements within a reduce group.

Parameters:

order - The order for the elements in a reduce group.

getGroupOrder

public Ordering getGroupOrder()

Gets the order of elements within a reduce group. If no such order has been set, this method returns null.

Returns:

The secondary order.

executeOnCollections

protected List<OUT> executeOnCollections(List<IN> inputData,
                                         RuntimeContext ctx,
                                         ExecutionConfig executionConfig)
                                  throws Exception

Specified by:

executeOnCollections in class SingleInputOperator<IN,OUT,FT extends GroupCombineFunction<IN,OUT>>

Throws:

Exception