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 org.apache.flink.configuration.ConfigOption<Integer>	CLIENT_CONNECT_TIMEOUT_SECONDS
static org.apache.flink.configuration.ConfigOption<Integer>	CONNECT_BACKLOG
static org.apache.flink.configuration.ConfigOption<Integer>	NUM_ARENAS
static org.apache.flink.configuration.ConfigOption<Integer>	NUM_THREADS_CLIENT
static org.apache.flink.configuration.ConfigOption<Integer>	NUM_THREADS_SERVER
static org.apache.flink.configuration.ConfigOption<Integer>	SEND_RECEIVE_BUFFER_SIZE
static org.apache.flink.configuration.ConfigOption<String>	TRANSPORT_TYPE

Constructor Summary

Constructors

Constructor and Description
NettyConfig(InetAddress serverAddress, Iterator<Integer> serverPortRange, int memorySegmentSize, int numberOfSlots, org.apache.flink.configuration.Configuration config)

Method Summary

Modifier and Type	Method and Description
SSLHandlerFactory	createClientSSLEngineFactory()
SSLHandlerFactory	createServerSSLEngineFactory()
int	getClientConnectTimeoutSeconds()
int	getClientNumThreads()
org.apache.flink.configuration.Configuration	getConfig()
int	getNumberOfArenas()
int	getNumberOfSlots()
int	getSendAndReceiveBufferSize()
int	getServerConnectBacklog()
int	getServerNumThreads()
int	getServerPort() Returns the port of this server.
boolean	getSSLEnabled()
org.apache.flink.runtime.io.network.netty.NettyConfig.TransportType	getTransportType()
boolean	isCreditBasedEnabled()
void	setServerPort(int port) Sets netty server port number from port range
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 org.apache.flink.configuration.ConfigOption<Integer> NUM_ARENAS

NUM_THREADS_SERVER

public static final org.apache.flink.configuration.ConfigOption<Integer> NUM_THREADS_SERVER

NUM_THREADS_CLIENT

public static final org.apache.flink.configuration.ConfigOption<Integer> NUM_THREADS_CLIENT

CONNECT_BACKLOG

public static final org.apache.flink.configuration.ConfigOption<Integer> CONNECT_BACKLOG

CLIENT_CONNECT_TIMEOUT_SECONDS

public static final org.apache.flink.configuration.ConfigOption<Integer> CLIENT_CONNECT_TIMEOUT_SECONDS

SEND_RECEIVE_BUFFER_SIZE

public static final org.apache.flink.configuration.ConfigOption<Integer> SEND_RECEIVE_BUFFER_SIZE

TRANSPORT_TYPE

public static final org.apache.flink.configuration.ConfigOption<String> TRANSPORT_TYPE

Constructor Detail

NettyConfig

public NettyConfig(InetAddress serverAddress,
                   Iterator<Integer> serverPortRange,
                   int memorySegmentSize,
                   int numberOfSlots,
                   org.apache.flink.configuration.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 org.apache.flink.configuration.Configuration getConfig()

toString

public String toString()

Overrides:

toString in class Object

getServerPort

public int getServerPort()

Returns the port of this server.

Returns:

Server port

Throws:

IllegalStateException - If server has not been started yet

setServerPort

public void setServerPort(int port)

Sets netty server port number from port range

Parameters:

port - netty server port number