Uses of Class
org.apache.flink.runtime.operators.shipping.ShipStrategyType
-
Packages that use ShipStrategyType Package Description org.apache.flink.runtime.io.network org.apache.flink.runtime.operators.shipping org.apache.flink.runtime.operators.util -
-
Uses of ShipStrategyType in org.apache.flink.runtime.io.network
Methods in org.apache.flink.runtime.io.network with parameters of type ShipStrategyType Modifier and Type Method Description static DataExchangeModeDataExchangeMode. select(org.apache.flink.api.common.ExecutionMode executionMode, ShipStrategyType shipStrategy, boolean breakPipeline)Computes the mode of data exchange to be used for a given execution mode and ship strategy. -
Uses of ShipStrategyType in org.apache.flink.runtime.operators.shipping
Methods in org.apache.flink.runtime.operators.shipping that return ShipStrategyType Modifier and Type Method Description static ShipStrategyTypeShipStrategyType. valueOf(String name)Returns the enum constant of this type with the specified name.static ShipStrategyType[]ShipStrategyType. values()Returns an array containing the constants of this enum type, in the order they are declared.Constructors in org.apache.flink.runtime.operators.shipping with parameters of type ShipStrategyType Constructor Description OutputEmitter(ShipStrategyType strategy, int indexInSubtaskGroup)Creates a new channel selector that uses the given strategy (broadcasting, partitioning, ...) and uses the supplied task index perform a round robin distribution.OutputEmitter(ShipStrategyType strategy, int indexInSubtaskGroup, org.apache.flink.api.common.typeutils.TypeComparator<T> comparator, org.apache.flink.api.common.functions.Partitioner<?> partitioner, org.apache.flink.api.common.distributions.DataDistribution distribution)OutputEmitter(ShipStrategyType strategy, org.apache.flink.api.common.typeutils.TypeComparator<T> comparator)Creates a new channel selector that uses the given strategy (broadcasting, partitioning, ...) and uses the supplied comparator to hash / compare records for partitioning them deterministically. -
Uses of ShipStrategyType in org.apache.flink.runtime.operators.util
Methods in org.apache.flink.runtime.operators.util that return ShipStrategyType Modifier and Type Method Description ShipStrategyTypeTaskConfig. getOutputShipStrategy(int outputNum)Methods in org.apache.flink.runtime.operators.util with parameters of type ShipStrategyType Modifier and Type Method Description voidTaskConfig. addOutputShipStrategy(ShipStrategyType strategy)
-