Package | Description |
---|---|
org.apache.flink.runtime.clusterframework |
This package contains the cluster resource management functionality.
|
org.apache.flink.runtime.resourcemanager |
Modifier and Type | Method and Description |
---|---|
TaskExecutorProcessSpec |
TaskExecutorProcessSpecBuilder.build() |
TaskExecutorProcessSpec |
ContaineredTaskManagerParameters.getTaskExecutorProcessSpec() |
static TaskExecutorProcessSpec |
TaskExecutorProcessUtils.processSpecFromConfig(Configuration config) |
Modifier and Type | Method and Description |
---|---|
static ContaineredTaskManagerParameters |
ContaineredTaskManagerParameters.create(Configuration config,
TaskExecutorProcessSpec taskExecutorProcessSpec,
int numSlots)
Computes the parameters to be used to start a TaskManager Java process.
|
static List<ResourceProfile> |
TaskExecutorProcessUtils.createDefaultWorkerSlotProfiles(TaskExecutorProcessSpec taskExecutorProcessSpec,
int numberOfSlots) |
static ResourceProfile |
TaskExecutorProcessUtils.generateDefaultSlotResourceProfile(TaskExecutorProcessSpec taskExecutorProcessSpec,
int numberOfSlots) |
static String |
TaskExecutorProcessUtils.generateDynamicConfigsStr(TaskExecutorProcessSpec taskExecutorProcessSpec) |
static String |
TaskExecutorProcessUtils.generateJvmParametersStr(TaskExecutorProcessSpec taskExecutorProcessSpec) |
static ResourceProfile |
TaskExecutorProcessUtils.generateTotalAvailableResourceProfile(TaskExecutorProcessSpec taskExecutorProcessSpec) |
Constructor and Description |
---|
ContaineredTaskManagerParameters(TaskExecutorProcessSpec taskExecutorProcessSpec,
int numSlots,
HashMap<String,String> taskManagerEnv) |
Modifier and Type | Field and Description |
---|---|
protected TaskExecutorProcessSpec |
ActiveResourceManager.taskExecutorProcessSpec |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.