Uses of Class
org.apache.flink.runtime.io.network.DataExchangeMode
-
Packages that use DataExchangeMode Package Description org.apache.flink.runtime.io.network -
-
Uses of DataExchangeMode in org.apache.flink.runtime.io.network
Methods in org.apache.flink.runtime.io.network that return DataExchangeMode Modifier and Type Method Description static DataExchangeModeDataExchangeMode. getForForwardExchange(org.apache.flink.api.common.ExecutionMode mode)static DataExchangeModeDataExchangeMode. getForShuffleOrBroadcast(org.apache.flink.api.common.ExecutionMode mode)static DataExchangeModeDataExchangeMode. getPipelineBreakingExchange(org.apache.flink.api.common.ExecutionMode mode)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.static DataExchangeModeDataExchangeMode. valueOf(String name)Returns the enum constant of this type with the specified name.static DataExchangeMode[]DataExchangeMode. values()Returns an array containing the constants of this enum type, in the order they are declared.
-