Package org.apache.flink.runtime.io.network.partition.consumer

Class InputGateSpecUtils

java.lang.Object

org.apache.flink.runtime.io.network.partition.consumer.InputGateSpecUtils

public class InputGateSpecUtils
extends Object

Utils to manage the specs of the InputGate, for example, GateBuffersSpec.

Field Summary

Fields

Modifier and Type	Field	Description
static int	DEFAULT_MAX_REQUIRED_BUFFERS_PER_GATE_FOR_BATCH
static int	DEFAULT_MAX_REQUIRED_BUFFERS_PER_GATE_FOR_STREAM

Constructor Summary

Constructors

Constructor	Description
InputGateSpecUtils()

Method Summary

Modifier and Type	Method	Description
static GateBuffersSpec	createGateBuffersSpec(Optional<Integer> configuredMaxRequiredBuffersPerGate, int configuredNetworkBuffersPerChannel, int configuredFloatingNetworkBuffersPerGate, ResultPartitionType partitionType, int numInputChannels, boolean enableTieredStorage)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DEFAULT_MAX_REQUIRED_BUFFERS_PER_GATE_FOR_BATCH

public static final int DEFAULT_MAX_REQUIRED_BUFFERS_PER_GATE_FOR_BATCH

See Also:

Constant Field Values

DEFAULT_MAX_REQUIRED_BUFFERS_PER_GATE_FOR_STREAM

public static final int DEFAULT_MAX_REQUIRED_BUFFERS_PER_GATE_FOR_STREAM

See Also:

Constant Field Values

Constructor Detail

InputGateSpecUtils

public InputGateSpecUtils()

Method Detail

createGateBuffersSpec

public static GateBuffersSpec createGateBuffersSpec(Optional<Integer> configuredMaxRequiredBuffersPerGate,
                                                    int configuredNetworkBuffersPerChannel,
                                                    int configuredFloatingNetworkBuffersPerGate,
                                                    ResultPartitionType partitionType,
                                                    int numInputChannels,
                                                    boolean enableTieredStorage)