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

Class PartitionOperatorBase<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.PartitionOperatorBase<IN>

Type Parameters:

IN - The input and result type.

All Implemented Interfaces:

Visitable<Operator<?>>

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PartitionOperatorBase.PartitionMethod

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	Description
PartitionOperatorBase(UnaryOperatorInformation<IN,IN> operatorInfo, PartitionOperatorBase.PartitionMethod pMethod, int[] keys, String name)
PartitionOperatorBase(UnaryOperatorInformation<IN,IN> operatorInfo, PartitionOperatorBase.PartitionMethod pMethod, String name)

Method Summary

Modifier and Type	Method	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)

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

accept, clearInputs, getInput, getKeyColumns, getNumberOfInputs, getOperatorInfo, setInput, 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, setResources, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

PartitionOperatorBase

public PartitionOperatorBase(UnaryOperatorInformation<IN,IN> operatorInfo,
                             PartitionOperatorBase.PartitionMethod pMethod,
                             int[] keys,
                             String name)

PartitionOperatorBase

public PartitionOperatorBase(UnaryOperatorInformation<IN,IN> operatorInfo,
                             PartitionOperatorBase.PartitionMethod pMethod,
                             String name)

Method Detail

getPartitionMethod

public PartitionOperatorBase.PartitionMethod getPartitionMethod()

getCustomPartitioner

public Partitioner<?> getCustomPartitioner()

getDistribution

public DataDistribution getDistribution()

setOrdering

public void setOrdering(Ordering ordering)

getOrdering

public Ordering getOrdering()

setDistribution

public void setDistribution(DataDistribution distribution)

setCustomPartitioner

public void setCustomPartitioner(Partitioner<?> customPartitioner)

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>