org.apache.flink.runtime.taskmanager

Class NetworkEnvironmentConfiguration

java.lang.Object

org.apache.flink.runtime.taskmanager.NetworkEnvironmentConfiguration

public class NetworkEnvironmentConfiguration
extends Object

Configuration object for the network stack.

Constructor Summary

Constructors

Constructor and Description
NetworkEnvironmentConfiguration(float networkBufFraction, long networkBufMin, long networkBufMax, int networkBufferSize, MemoryType memoryType, IOManager.IOMode ioMode, int partitionRequestInitialBackoff, int partitionRequestMaxBackoff, int networkBuffersPerChannel, int floatingNetworkBuffersPerGate) Constructor for a setup with purely local communication (no netty).
NetworkEnvironmentConfiguration(float networkBufFraction, long networkBufMin, long networkBufMax, int networkBufferSize, MemoryType memoryType, IOManager.IOMode ioMode, int partitionRequestInitialBackoff, int partitionRequestMaxBackoff, int networkBuffersPerChannel, int floatingNetworkBuffersPerGate, NettyConfig nettyConfig)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object obj)
int	floatingNetworkBuffersPerGate()
int	hashCode()
IOManager.IOMode	ioMode()
MemoryType	memoryType()
NettyConfig	nettyConfig()
int	networkBufferSize()
int	networkBuffersPerChannel()
float	networkBufFraction()
long	networkBufMax()
long	networkBufMin()
int	partitionRequestInitialBackoff()
int	partitionRequestMaxBackoff()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

NetworkEnvironmentConfiguration

public NetworkEnvironmentConfiguration(float networkBufFraction,
                                       long networkBufMin,
                                       long networkBufMax,
                                       int networkBufferSize,
                                       MemoryType memoryType,
                                       IOManager.IOMode ioMode,
                                       int partitionRequestInitialBackoff,
                                       int partitionRequestMaxBackoff,
                                       int networkBuffersPerChannel,
                                       int floatingNetworkBuffersPerGate)

Constructor for a setup with purely local communication (no netty).

NetworkEnvironmentConfiguration

public NetworkEnvironmentConfiguration(float networkBufFraction,
                                       long networkBufMin,
                                       long networkBufMax,
                                       int networkBufferSize,
                                       MemoryType memoryType,
                                       IOManager.IOMode ioMode,
                                       int partitionRequestInitialBackoff,
                                       int partitionRequestMaxBackoff,
                                       int networkBuffersPerChannel,
                                       int floatingNetworkBuffersPerGate,
                                       @Nullable
                                       NettyConfig nettyConfig)

Method Detail

networkBufFraction

public float networkBufFraction()

networkBufMin

public long networkBufMin()

networkBufMax

public long networkBufMax()

networkBufferSize

public int networkBufferSize()

memoryType

public MemoryType memoryType()

ioMode

public IOManager.IOMode ioMode()

partitionRequestInitialBackoff

public int partitionRequestInitialBackoff()

partitionRequestMaxBackoff

public int partitionRequestMaxBackoff()

networkBuffersPerChannel

public int networkBuffersPerChannel()

floatingNetworkBuffersPerGate

public int floatingNetworkBuffersPerGate()

nettyConfig

public NettyConfig nettyConfig()

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object