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

Class SortPartitionOperatorBase<IN>

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,IN,NoOpFunction>

org.apache.flink.api.common.operators.base.SortPartitionOperatorBase<IN>

Type Parameters:

IN - The input and result type.

All Implemented Interfaces:

Visitable<Operator<?>>

@Internal
public class SortPartitionOperatorBase<IN>
extends SingleInputOperator<IN,IN,NoOpFunction>

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
SortPartitionOperatorBase(UnaryOperatorInformation<IN,IN> operatorInfo, Ordering partitionOrdering, String name)

Method Summary

Modifier and Type	Method and Description
protected List<IN>	executeOnCollections(List<IN> inputData, RuntimeContext runtimeContext, ExecutionConfig executionConfig)
Ordering	getPartitionOrdering()
SingleInputSemanticProperties	getSemanticProperties()

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

accept, addInput, addInput, clearInputs, getInput, getKeyColumns, getNumberOfInputs, getOperatorInfo, 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

SortPartitionOperatorBase

public SortPartitionOperatorBase(UnaryOperatorInformation<IN,IN> operatorInfo,
                                 Ordering partitionOrdering,
                                 String name)

Method Detail

getPartitionOrdering

public Ordering getPartitionOrdering()

getSemanticProperties

public SingleInputSemanticProperties getSemanticProperties()

Overrides:

getSemanticProperties in class SingleInputOperator<IN,IN,NoOpFunction>

executeOnCollections

protected List<IN> executeOnCollections(List<IN> inputData,
                                        RuntimeContext runtimeContext,
                                        ExecutionConfig executionConfig)

Specified by:

executeOnCollections in class SingleInputOperator<IN,IN,NoOpFunction>