Package | Description |
---|---|
org.apache.flink.runtime.taskexecutor |
Modifier and Type | Method and Description |
---|---|
static TaskManagerServicesConfiguration |
TaskManagerServicesConfiguration.fromConfiguration(Configuration configuration,
InetAddress remoteAddress,
boolean localCommunication)
Utility method to extract TaskManager config parameters from the configuration and to
sanity check them.
|
Modifier and Type | Method and Description |
---|---|
static long |
TaskManagerServices.calculateNetworkBufferMemory(TaskManagerServicesConfiguration tmConfig)
Calculates the amount of memory used for network buffers inside the current JVM instance
based on the available heap or the max heap size and the according configuration parameters.
|
static TaskManagerServices |
TaskManagerServices.fromConfiguration(TaskManagerServicesConfiguration taskManagerServicesConfiguration,
ResourceID resourceID)
Creates and returns the task manager services.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.