IN
- The input and result type.@Internal public class PartitionOperatorBase<IN> extends SingleInputOperator<IN,IN,NoOpFunction>
Modifier and Type | Class and Description |
---|---|
static class |
PartitionOperatorBase.PartitionMethod |
input
broadcastInputs, userFunction
compilerHints, name, operatorInfo, parameters
Constructor and Description |
---|
PartitionOperatorBase(UnaryOperatorInformation<IN,IN> operatorInfo,
PartitionOperatorBase.PartitionMethod pMethod,
int[] keys,
String name) |
PartitionOperatorBase(UnaryOperatorInformation<IN,IN> operatorInfo,
PartitionOperatorBase.PartitionMethod pMethod,
String name) |
Modifier and Type | Method and Description |
---|---|
protected List<IN> |
executeOnCollections(List<IN> inputData,
RuntimeContext runtimeContext,
ExecutionConfig executionConfig) |
Partitioner<?> |
getCustomPartitioner() |
DataDistribution |
getDistribution() |
Ordering |
getOrdering() |
PartitionOperatorBase.PartitionMethod |
getPartitionMethod() |
SingleInputSemanticProperties |
getSemanticProperties() |
void |
setCustomPartitioner(Partitioner<?> customPartitioner) |
void |
setDistribution(DataDistribution distribution) |
void |
setOrdering(Ordering ordering) |
accept, addInput, addInput, clearInputs, getInput, getKeyColumns, getNumberOfInputs, getOperatorInfo, setInput, setInput, setInputs, setSemanticProperties
asArray, emptyClassArray, getBroadcastInputs, getUserCodeWrapper, setBroadcastVariable, setBroadcastVariables
createUnionCascade, createUnionCascade, createUnionCascade, getCompilerHints, getMinResources, getName, getParallelism, getParameters, getPreferredResources, setName, setParallelism, setParameter, setParameter, setParameter, setResources, toString
public PartitionOperatorBase(UnaryOperatorInformation<IN,IN> operatorInfo, PartitionOperatorBase.PartitionMethod pMethod, int[] keys, String name)
public PartitionOperatorBase(UnaryOperatorInformation<IN,IN> operatorInfo, PartitionOperatorBase.PartitionMethod pMethod, String name)
public PartitionOperatorBase.PartitionMethod getPartitionMethod()
public Partitioner<?> getCustomPartitioner()
public DataDistribution getDistribution()
public void setOrdering(Ordering ordering)
public Ordering getOrdering()
public void setDistribution(DataDistribution distribution)
public void setCustomPartitioner(Partitioner<?> customPartitioner)
public SingleInputSemanticProperties getSemanticProperties()
getSemanticProperties
in class SingleInputOperator<IN,IN,NoOpFunction>
protected List<IN> executeOnCollections(List<IN> inputData, RuntimeContext runtimeContext, ExecutionConfig executionConfig)
executeOnCollections
in class SingleInputOperator<IN,IN,NoOpFunction>
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.