Uses of Interface
org.apache.flink.api.common.functions.Partitioner

Packages that use Partitioner

Package	Description
org.apache.flink.api.common.operators
org.apache.flink.api.common.operators.base
org.apache.flink.api.java.typeutils

Uses of Partitioner in org.apache.flink.api.common.operators

Methods in org.apache.flink.api.common.operators that return Partitioner

Modifier and Type	Method	Description
Partitioner<T>	GenericDataSourceBase.SplitDataProperties.getSplitPartitioner()

Methods in org.apache.flink.api.common.operators with parameters of type Partitioner

Modifier and Type	Method	Description
<E> void	Keys.ExpressionKeys.validateCustomPartitioner(Partitioner<E> partitioner, TypeInformation<E> typeInfo)
<E> void	Keys.SelectorFunctionKeys.validateCustomPartitioner(Partitioner<E> partitioner, TypeInformation<E> typeInfo)
abstract <E> void	Keys.validateCustomPartitioner(Partitioner<E> partitioner, TypeInformation<E> typeInfo)

Uses of Partitioner in org.apache.flink.api.common.operators.base

Methods in org.apache.flink.api.common.operators.base that return Partitioner

Modifier and Type	Method	Description
Partitioner<?>	CoGroupOperatorBase.getCustomPartitioner()
Partitioner<?>	GroupReduceOperatorBase.getCustomPartitioner()
Partitioner<?>	JoinOperatorBase.getCustomPartitioner()
Partitioner<?>	PartitionOperatorBase.getCustomPartitioner()
Partitioner<?>	ReduceOperatorBase.getCustomPartitioner()

Methods in org.apache.flink.api.common.operators.base with parameters of type Partitioner

Modifier and Type	Method	Description
void	CoGroupOperatorBase.setCustomPartitioner(Partitioner<?> customPartitioner)
void	GroupReduceOperatorBase.setCustomPartitioner(Partitioner<?> customPartitioner)
void	JoinOperatorBase.setCustomPartitioner(Partitioner<?> partitioner)
void	PartitionOperatorBase.setCustomPartitioner(Partitioner<?> customPartitioner)
void	ReduceOperatorBase.setCustomPartitioner(Partitioner<?> customPartitioner)

Uses of Partitioner in org.apache.flink.api.java.typeutils

Methods in org.apache.flink.api.java.typeutils with parameters of type Partitioner

Modifier and Type	Method	Description
static <T> TypeInformation<T>	TypeExtractor.getPartitionerTypes(Partitioner<T> partitioner)
static <T> TypeInformation<T>	TypeExtractor.getPartitionerTypes(Partitioner<T> partitioner, String functionName, boolean allowMissing)