public static NetworkEnvironmentConfiguration fromConfiguration ( Configuration configuration , long maxJvmHeapMemory , boolean localTaskManagerCommunication , InetAddress taskManagerAddress ) { final int dataport = getDataport ( configuration ) ; final int pageSize = getPageSize ( configuration ) ; final int numberOfNetworkBuffers = calculateNumberOfNetworkBuffers ( configuration , maxJvmHeapMemory ) ; final NettyConfig nettyConfig = createNettyConfig ( configuration , localTaskManagerCommunication , taskManagerAddress , dataport ) ; int initialRequestBackoff = configuration . getInteger ( TaskManagerOptions . NETWORK_REQUEST_BACKOFF_INITIAL ) ; int maxRequestBackoff = configuration . getInteger ( TaskManagerOptions . NETWORK_REQUEST_BACKOFF_MAX ) ; int buffersPerChannel = configuration . getInteger ( TaskManagerOptions . NETWORK_BUFFERS_PER_CHANNEL ) ; int extraBuffersPerGate = configuration . getInteger ( TaskManagerOptions . NETWORK_EXTRA_BUFFERS_PER_GATE ) ; boolean isCreditBased = nettyConfig != null && configuration . getBoolean ( TaskManagerOptions . NETWORK_CREDIT_MODEL ) ; return new NetworkEnvironmentConfiguration ( numberOfNetworkBuffers , pageSize , initialRequestBackoff , maxRequestBackoff , buffersPerChannel , extraBuffersPerGate , isCreditBased , nettyConfig ) ; }
Utility method to extract network related parameters from the configuration and to sanity check them .