Package | Description |
---|---|
org.apache.flink.runtime.taskexecutor |
Modifier and Type | Method and Description |
---|---|
TaskExecutorResourceSpec |
TaskManagerServicesConfiguration.getTaskExecutorResourceSpec() |
static TaskExecutorResourceSpec |
TaskExecutorResourceUtils.resourceSpecFromConfigForLocalExecution(Configuration config) |
Modifier and Type | Method and Description |
---|---|
static TaskManagerServicesConfiguration |
TaskManagerServicesConfiguration.fromConfiguration(Configuration configuration,
ResourceID resourceID,
String externalAddress,
boolean localCommunicationOnly,
TaskExecutorResourceSpec taskExecutorResourceSpec,
WorkingDirectory workingDirectory)
Utility method to extract TaskManager config parameters from the configuration and to sanity
check them.
|
static TaskManagerConfiguration |
TaskManagerConfiguration.fromConfiguration(Configuration configuration,
TaskExecutorResourceSpec taskExecutorResourceSpec,
String externalAddress,
File tmpWorkingDirectory) |
static ResourceProfile |
TaskExecutorResourceUtils.generateDefaultSlotResourceProfile(TaskExecutorResourceSpec taskExecutorResourceSpec,
int numberOfSlots)
|
static ResourceProfile |
TaskExecutorResourceUtils.generateTotalAvailableResourceProfile(TaskExecutorResourceSpec taskExecutorResourceSpec) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.