IN
- The input and result type.@Internal public class SortPartitionOperatorBase<IN> extends SingleInputOperator<IN,IN,NoOpFunction>
input
broadcastInputs, userFunction
compilerHints, name, operatorInfo, parameters
Constructor and Description |
---|
SortPartitionOperatorBase(UnaryOperatorInformation<IN,IN> operatorInfo,
Ordering partitionOrdering,
String name) |
Modifier and Type | Method and Description |
---|---|
protected List<IN> |
executeOnCollections(List<IN> inputData,
RuntimeContext runtimeContext,
ExecutionConfig executionConfig) |
Ordering |
getPartitionOrdering() |
SingleInputSemanticProperties |
getSemanticProperties() |
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 SortPartitionOperatorBase(UnaryOperatorInformation<IN,IN> operatorInfo, Ordering partitionOrdering, String name)
public Ordering getPartitionOrdering()
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.