Package | Description |
---|---|
org.apache.flink.runtime.io.network.netty | |
org.apache.flink.runtime.taskmanager |
Modifier and Type | Method and Description |
---|---|
NettyConfig |
NettyConfig.setClientConnectTimeoutSeconds(int connectTimeoutSeconds) |
NettyConfig |
NettyConfig.setClientNumThreads(int numThreads) |
NettyConfig |
NettyConfig.setSendAndReceiveBufferSize(int bufferSize) |
NettyConfig |
NettyConfig.setServerConnectBacklog(int connectBacklog) |
NettyConfig |
NettyConfig.setServerNumThreads(int numThreads) |
NettyConfig |
NettyConfig.setTransportType(String transport) |
Constructor and Description |
---|
NettyConnectionManager(NettyConfig nettyConfig) |
Modifier and Type | Method and Description |
---|---|
scala.Option<NettyConfig> |
NetworkEnvironmentConfiguration.nettyConfig() |
Constructor and Description |
---|
NetworkEnvironmentConfiguration(int numNetworkBuffers,
int networkBufferSize,
MemoryType memoryType,
IOManager.IOMode ioMode,
scala.Tuple2<Integer,Integer> partitionRequestInitialMaxBackoff,
scala.Option<NettyConfig> nettyConfig) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.