Uses of Interface
org.apache.flink.api.common.distributions.DataDistribution

Packages that use DataDistribution

Package	Description
org.apache.flink.api.common.operators.base
org.apache.flink.api.java.operators
org.apache.flink.api.java.utils
org.apache.flink.optimizer.dag
org.apache.flink.optimizer.dataproperties
org.apache.flink.optimizer.plan
org.apache.flink.runtime.operators.shipping
org.apache.flink.runtime.operators.util

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

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

Modifier and Type	Method and Description
DataDistribution	PartitionOperatorBase.getDistribution()

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

Modifier and Type	Method and Description
void	PartitionOperatorBase.setDistribution(DataDistribution distribution)

Uses of DataDistribution in org.apache.flink.api.java.operators

Constructors in org.apache.flink.api.java.operators with parameters of type DataDistribution

Constructor and Description
PartitionOperator(DataSet<T> input, PartitionOperatorBase.PartitionMethod pMethod, Keys<T> pKeys, DataDistribution distribution, String partitionLocationName) Deprecated.

Uses of DataDistribution in org.apache.flink.api.java.utils

Methods in org.apache.flink.api.java.utils with parameters of type DataDistribution

Modifier and Type	Method and Description
static <T> PartitionOperator<T>	DataSetUtils.partitionByRange(DataSet<T> input, DataDistribution distribution, int... fields) Deprecated. Range-partitions a DataSet on the specified tuple field positions.
static <T,K extends Comparable<K>> PartitionOperator<T>	DataSetUtils.partitionByRange(DataSet<T> input, DataDistribution distribution, KeySelector<T,K> keyExtractor) Deprecated. Range-partitions a DataSet using the specified key selector function.
static <T> PartitionOperator<T>	DataSetUtils.partitionByRange(DataSet<T> input, DataDistribution distribution, String... fields) Deprecated. Range-partitions a DataSet on the specified fields.

Uses of DataDistribution in org.apache.flink.optimizer.dag

Constructors in org.apache.flink.optimizer.dag with parameters of type DataDistribution

Constructor and Description
PartitionDescriptor(PartitionOperatorBase.PartitionMethod pMethod, FieldSet pKeys, Ordering ordering, Partitioner<?> customPartitioner, DataDistribution distribution)

Uses of DataDistribution in org.apache.flink.optimizer.dataproperties

Methods in org.apache.flink.optimizer.dataproperties that return DataDistribution

Modifier and Type	Method and Description
DataDistribution	GlobalProperties.getDataDistribution()
DataDistribution	RequestedGlobalProperties.getDataDistribution() Gets the data distribution.

Methods in org.apache.flink.optimizer.dataproperties with parameters of type DataDistribution

Modifier and Type	Method and Description
void	GlobalProperties.setRangePartitioned(Ordering ordering, DataDistribution distribution) Set the parameters for range partition.
void	RequestedGlobalProperties.setRangePartitioned(Ordering ordering, DataDistribution dataDistribution)

Uses of DataDistribution in org.apache.flink.optimizer.plan

Methods in org.apache.flink.optimizer.plan that return DataDistribution

Modifier and Type	Method and Description
DataDistribution	Channel.getDataDistribution()

Methods in org.apache.flink.optimizer.plan with parameters of type DataDistribution

Modifier and Type	Method and Description
void	Channel.setDataDistribution(DataDistribution dataDistribution)

Uses of DataDistribution in org.apache.flink.runtime.operators.shipping

Constructors in org.apache.flink.runtime.operators.shipping with parameters of type DataDistribution

Constructor and Description
OutputEmitter(ShipStrategyType strategy, int indexInSubtaskGroup, TypeComparator<T> comparator, Partitioner<?> partitioner, DataDistribution distribution)

Uses of DataDistribution in org.apache.flink.runtime.operators.util

Methods in org.apache.flink.runtime.operators.util that return DataDistribution

Modifier and Type	Method and Description
DataDistribution	TaskConfig.getOutputDataDistribution(int outputNum, ClassLoader cl)

Methods in org.apache.flink.runtime.operators.util with parameters of type DataDistribution

Modifier and Type	Method and Description
void	TaskConfig.setOutputDataDistribution(DataDistribution distribution, int outputNum)