Uses of Class
org.apache.flink.runtime.io.network.netty.NettyConfig
-
Packages that use NettyConfig Package Description org.apache.flink.runtime.io.network.netty org.apache.flink.runtime.taskmanager -
-
Uses of NettyConfig in org.apache.flink.runtime.io.network.netty
Constructors in org.apache.flink.runtime.io.network.netty with parameters of type NettyConfig Constructor Description NettyConnectionManager(NettyBufferPool bufferPool, ResultPartitionProvider partitionProvider, TaskEventPublisher taskEventPublisher, NettyConfig nettyConfig, int maxNumberOfConnections, boolean connectionReuseEnabled)NettyConnectionManager(ResultPartitionProvider partitionProvider, TaskEventPublisher taskEventPublisher, NettyConfig nettyConfig, int maxNumberOfConnections, boolean connectionReuseEnabled) -
Uses of NettyConfig in org.apache.flink.runtime.taskmanager
Methods in org.apache.flink.runtime.taskmanager that return NettyConfig Modifier and Type Method Description NettyConfigNettyShuffleEnvironmentConfiguration. nettyConfig()Constructors in org.apache.flink.runtime.taskmanager with parameters of type NettyConfig Constructor Description NettyShuffleEnvironmentConfiguration(int numNetworkBuffers, int networkBufferSize, int partitionRequestInitialBackoff, int partitionRequestMaxBackoff, int networkBuffersPerChannel, int floatingNetworkBuffersPerGate, Optional<Integer> maxRequiredBuffersPerGate, java.time.Duration requestSegmentsTimeout, boolean isNetworkDetailedMetrics, NettyConfig nettyConfig, String[] tempDirs, BoundedBlockingSubpartitionType blockingSubpartitionType, boolean batchShuffleCompressionEnabled, String compressionCodec, int maxBuffersPerChannel, long batchShuffleReadMemoryBytes, int sortShuffleMinBuffers, int sortShuffleMinParallelism, BufferDebloatConfiguration debloatConfiguration, int maxNumberOfConnections, boolean connectionReuseEnabled, int maxOverdraftBuffersPerGate, int hybridShuffleSpilledIndexRegionGroupSize, long hybridShuffleNumRetainedInMemoryRegionsMax, TieredStorageConfiguration tieredStorageConfiguration)
-