public class NettyConfig extends Object
Modifier and Type | Field and Description |
---|---|
static String |
CLIENT_CONNECT_TIMEOUT_SECONDS |
static String |
CONNECT_BACKLOG |
static String |
NUM_ARENAS |
static String |
NUM_THREADS_CLIENT |
static String |
NUM_THREADS_SERVER |
static String |
SEND_RECEIVE_BUFFER_SIZE |
static String |
TRANSPORT_TYPE |
Constructor and Description |
---|
NettyConfig(InetAddress serverAddress,
int serverPort,
int memorySegmentSize,
int numberOfSlots,
Configuration config) |
Modifier and Type | Method and Description |
---|---|
SSLContext |
createClientSSLContext() |
SSLContext |
createServerSSLContext() |
int |
getClientConnectTimeoutSeconds() |
int |
getClientNumThreads() |
int |
getNumberOfArenas() |
int |
getNumberOfSlots() |
int |
getSendAndReceiveBufferSize() |
int |
getServerConnectBacklog() |
int |
getServerNumThreads() |
boolean |
getSSLEnabled() |
org.apache.flink.runtime.io.network.netty.NettyConfig.TransportType |
getTransportType() |
NettyConfig |
setClientConnectTimeoutSeconds(int connectTimeoutSeconds) |
NettyConfig |
setClientNumThreads(int numThreads) |
NettyConfig |
setSendAndReceiveBufferSize(int bufferSize) |
NettyConfig |
setServerConnectBacklog(int connectBacklog) |
NettyConfig |
setServerNumThreads(int numThreads) |
void |
setSSLVerifyHostname(SSLParameters sslParams) |
NettyConfig |
setTransportType(String transport) |
String |
toString() |
public static final String NUM_ARENAS
public static final String NUM_THREADS_SERVER
public static final String NUM_THREADS_CLIENT
public static final String CONNECT_BACKLOG
public static final String CLIENT_CONNECT_TIMEOUT_SECONDS
public static final String SEND_RECEIVE_BUFFER_SIZE
public static final String TRANSPORT_TYPE
public NettyConfig(InetAddress serverAddress, int serverPort, int memorySegmentSize, int numberOfSlots, Configuration config)
public int getNumberOfSlots()
public NettyConfig setServerConnectBacklog(int connectBacklog)
public NettyConfig setServerNumThreads(int numThreads)
public NettyConfig setClientNumThreads(int numThreads)
public NettyConfig setClientConnectTimeoutSeconds(int connectTimeoutSeconds)
public NettyConfig setSendAndReceiveBufferSize(int bufferSize)
public NettyConfig setTransportType(String transport)
public int getServerConnectBacklog()
public int getNumberOfArenas()
public int getServerNumThreads()
public int getClientNumThreads()
public int getClientConnectTimeoutSeconds()
public int getSendAndReceiveBufferSize()
public org.apache.flink.runtime.io.network.netty.NettyConfig.TransportType getTransportType()
public SSLContext createClientSSLContext() throws Exception
Exception
public SSLContext createServerSSLContext() throws Exception
Exception
public boolean getSSLEnabled()
public void setSSLVerifyHostname(SSLParameters sslParams)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.