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.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 Description DataDistribution
PartitionOperatorBase. getDistribution()
Methods in org.apache.flink.api.common.operators.base with parameters of type DataDistribution Modifier and Type Method Description void
PartitionOperatorBase. setDistribution(DataDistribution distribution)
-
Uses of DataDistribution in org.apache.flink.runtime.operators.shipping
Constructors in org.apache.flink.runtime.operators.shipping with parameters of type DataDistribution Constructor 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 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 Description void
TaskConfig. setOutputDataDistribution(DataDistribution distribution, int outputNum)
-