org.apache.flink.runtime.io.network.netty

Class NettyConfig

java.lang.Object

org.apache.flink.runtime.io.network.netty.NettyConfig

public class NettyConfig
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static ConfigOption<Integer>	CLIENT_CONNECT_TIMEOUT_SECONDS
static ConfigOption<Integer>	CONNECT_BACKLOG
static ConfigOption<Integer>	NUM_ARENAS
static ConfigOption<Integer>	NUM_THREADS_CLIENT
static ConfigOption<Integer>	NUM_THREADS_SERVER
static ConfigOption<Integer>	SEND_RECEIVE_BUFFER_SIZE
static ConfigOption<String>	TRANSPORT_TYPE

Constructor Summary

Constructors

Constructor and Description
NettyConfig(InetAddress serverAddress, int serverPort, int memorySegmentSize, int numberOfSlots, Configuration config)

Method Summary

Modifier and Type	Method and Description
SSLHandlerFactory	createClientSSLEngineFactory()
SSLHandlerFactory	createServerSSLEngineFactory()
int	getClientConnectTimeoutSeconds()
int	getClientNumThreads()
Configuration	getConfig()
int	getNumberOfArenas()
int	getNumberOfSlots()
int	getSendAndReceiveBufferSize()
int	getServerConnectBacklog()
int	getServerNumThreads()
boolean	getSSLEnabled()
org.apache.flink.runtime.io.network.netty.NettyConfig.TransportType	getTransportType()
boolean	isCreditBasedEnabled()
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

NUM_ARENAS

public static final ConfigOption<Integer> NUM_ARENAS

NUM_THREADS_SERVER

public static final ConfigOption<Integer> NUM_THREADS_SERVER

NUM_THREADS_CLIENT

public static final ConfigOption<Integer> NUM_THREADS_CLIENT

CONNECT_BACKLOG

public static final ConfigOption<Integer> CONNECT_BACKLOG

CLIENT_CONNECT_TIMEOUT_SECONDS

public static final ConfigOption<Integer> CLIENT_CONNECT_TIMEOUT_SECONDS

SEND_RECEIVE_BUFFER_SIZE

public static final ConfigOption<Integer> SEND_RECEIVE_BUFFER_SIZE

TRANSPORT_TYPE

public static final ConfigOption<String> TRANSPORT_TYPE

Constructor Detail

NettyConfig

public NettyConfig(InetAddress serverAddress,
                   int serverPort,
                   int memorySegmentSize,
                   int numberOfSlots,
                   Configuration config)

Method Detail

getNumberOfSlots

public int getNumberOfSlots()

getServerConnectBacklog

public int getServerConnectBacklog()

getNumberOfArenas

public int getNumberOfArenas()

getServerNumThreads

public int getServerNumThreads()

getClientNumThreads

public int getClientNumThreads()

getClientConnectTimeoutSeconds

public int getClientConnectTimeoutSeconds()

getSendAndReceiveBufferSize

public int getSendAndReceiveBufferSize()

getTransportType

public org.apache.flink.runtime.io.network.netty.NettyConfig.TransportType getTransportType()

createClientSSLEngineFactory

@Nullable
public SSLHandlerFactory createClientSSLEngineFactory()
                                                         throws Exception

Throws:

Exception

createServerSSLEngineFactory

@Nullable
public SSLHandlerFactory createServerSSLEngineFactory()
                                                         throws Exception

Throws:

Exception

getSSLEnabled

public boolean getSSLEnabled()

isCreditBasedEnabled

public boolean isCreditBasedEnabled()

getConfig

public Configuration getConfig()

toString

public String toString()

Overrides:

toString in class Object