Package | Description |
---|---|
org.apache.flink.kubernetes | |
org.apache.flink.runtime.clusterframework |
This package contains the cluster resource management functionality.
|
org.apache.flink.runtime.resourcemanager | |
org.apache.flink.runtime.resourcemanager.active | |
org.apache.flink.yarn |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<KubernetesWorkerNode> |
KubernetesResourceManagerDriver.requestResource(TaskExecutorProcessSpec taskExecutorProcessSpec) |
Modifier and Type | Method and Description |
---|---|
TaskExecutorProcessSpec |
TaskExecutorProcessSpecBuilder.build() |
TaskExecutorProcessSpec |
ContaineredTaskManagerParameters.getTaskExecutorProcessSpec() |
static TaskExecutorProcessSpec |
TaskExecutorProcessUtils.processSpecFromConfig(Configuration config) |
static TaskExecutorProcessSpec |
TaskExecutorProcessUtils.processSpecFromWorkerResourceSpec(Configuration config,
WorkerResourceSpec workerResourceSpec) |
Modifier and Type | Method and Description |
---|---|
static ContaineredTaskManagerParameters |
ContaineredTaskManagerParameters.create(Configuration config,
TaskExecutorProcessSpec taskExecutorProcessSpec)
Computes the parameters to be used to start a TaskManager Java process.
|
static String |
TaskExecutorProcessUtils.generateDynamicConfigsStr(TaskExecutorProcessSpec taskExecutorProcessSpec) |
Constructor and Description |
---|
ContaineredTaskManagerParameters(TaskExecutorProcessSpec taskExecutorProcessSpec,
HashMap<String,String> taskManagerEnv) |
Modifier and Type | Method and Description |
---|---|
static WorkerResourceSpec |
WorkerResourceSpec.fromTaskExecutorProcessSpec(TaskExecutorProcessSpec taskExecutorProcessSpec) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<WorkerType> |
ResourceManagerDriver.requestResource(TaskExecutorProcessSpec taskExecutorProcessSpec)
Request resource from the external resource manager.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<YarnWorkerNode> |
YarnResourceManagerDriver.requestResource(TaskExecutorProcessSpec taskExecutorProcessSpec) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.