Uses of Class
org.apache.flink.runtime.operators.shipping.ShipStrategyType
-
Packages that use ShipStrategyType Package Description org.apache.flink.runtime.operators.shipping org.apache.flink.runtime.operators.util -
-
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, ...)OutputEmitter(ShipStrategyType strategy, int indexInSubtaskGroup, TypeComparator<T> comparator, Partitioner<?> partitioner, DataDistribution distribution)OutputEmitter(ShipStrategyType strategy, TypeComparator<T> comparator)Creates a new channel selector that uses the given strategy (broadcasting, partitioning, ...) -
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)
-