@Internal public class CoGroupRawOperatorBase<IN1,IN2,OUT,FT extends CoGroupFunction<IN1,IN2,OUT>> extends DualInputOperator<IN1,IN2,OUT,FT>
CoGroupFunction
Modifier and Type | Class and Description |
---|---|
static class |
CoGroupRawOperatorBase.SimpleListIterable<IN> |
input1, input2
broadcastInputs, userFunction
compilerHints, name, operatorInfo, parameters
Constructor and Description |
---|
CoGroupRawOperatorBase(Class<? extends FT> udf,
BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo,
int[] keyPositions1,
int[] keyPositions2,
String name) |
CoGroupRawOperatorBase(FT udf,
BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo,
int[] keyPositions1,
int[] keyPositions2,
String name) |
CoGroupRawOperatorBase(UserCodeWrapper<FT> udf,
BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo,
int[] keyPositions1,
int[] keyPositions2,
String name) |
Modifier and Type | Method and Description |
---|---|
protected List<OUT> |
executeOnCollections(List<IN1> input1,
List<IN2> input2,
RuntimeContext ctx,
ExecutionConfig executionConfig) |
Ordering |
getGroupOrder(int inputNum)
Gets the value order for an input, i.e.
|
Ordering |
getGroupOrderForInputOne()
Gets the order of elements within a group for the first input.
|
Ordering |
getGroupOrderForInputTwo()
Gets the order of elements within a group for the second input.
|
boolean |
isCombinableFirst() |
boolean |
isCombinableSecond() |
void |
setCombinableFirst(boolean combinableFirst) |
void |
setCombinableSecond(boolean combinableSecond) |
void |
setGroupOrder(int inputNum,
Ordering order)
Sets the order of the elements within a group for the given input.
|
void |
setGroupOrderForInputOne(Ordering order)
Sets the order of the elements within a group for the first input.
|
void |
setGroupOrderForInputTwo(Ordering order)
Sets the order of the elements within a group for the second input.
|
accept, addFirstInput, addFirstInputs, addSecondInput, addSecondInputs, clearFirstInput, clearSecondInput, getFirstInput, getKeyColumns, getNumberOfInputs, getOperatorInfo, getSecondInput, getSemanticProperties, setFirstInput, setFirstInput, setFirstInputs, setSecondInput, setSecondInput, setSecondInputs, setSemanticProperties
asArray, emptyClassArray, getBroadcastInputs, getUserCodeWrapper, setBroadcastVariable, setBroadcastVariables
createUnionCascade, createUnionCascade, createUnionCascade, getCompilerHints, getMinResources, getName, getParallelism, getParameters, getPreferredResources, setName, setParallelism, setParameter, setParameter, setParameter, setResources, toString
public CoGroupRawOperatorBase(UserCodeWrapper<FT> udf, BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo, int[] keyPositions1, int[] keyPositions2, String name)
public CoGroupRawOperatorBase(FT udf, BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo, int[] keyPositions1, int[] keyPositions2, String name)
public void setGroupOrder(int inputNum, Ordering order)
inputNum
- The number of the input (here either 0 or 1).order
- The order for the elements in a group.public void setGroupOrderForInputOne(Ordering order)
order
- The order for the elements in a group.public void setGroupOrderForInputTwo(Ordering order)
order
- The order for the elements in a group.public Ordering getGroupOrder(int inputNum)
inputNum
- The number of the input (here either 0 or 1).public Ordering getGroupOrderForInputOne()
public Ordering getGroupOrderForInputTwo()
public boolean isCombinableFirst()
public void setCombinableFirst(boolean combinableFirst)
public boolean isCombinableSecond()
public void setCombinableSecond(boolean combinableSecond)
protected List<OUT> executeOnCollections(List<IN1> input1, List<IN2> input2, RuntimeContext ctx, ExecutionConfig executionConfig) throws Exception
executeOnCollections
in class DualInputOperator<IN1,IN2,OUT,FT extends CoGroupFunction<IN1,IN2,OUT>>
Exception
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.