Package | Description |
---|---|
org.apache.flink.kubernetes | |
org.apache.flink.kubernetes.entrypoint | |
org.apache.flink.mesos.runtime.clusterframework | |
org.apache.flink.mesos.runtime.clusterframework.store | |
org.apache.flink.runtime.clusterframework |
This package contains the cluster resource management functionality.
|
org.apache.flink.runtime.resourcemanager | |
org.apache.flink.runtime.resourcemanager.slotmanager | |
org.apache.flink.yarn | |
org.apache.flink.yarn.entrypoint |
Modifier and Type | Method and Description |
---|---|
boolean |
KubernetesResourceManager.startNewWorker(WorkerResourceSpec workerResourceSpec) |
Modifier and Type | Method and Description |
---|---|
WorkerResourceSpec |
KubernetesWorkerResourceSpecFactory.createDefaultWorkerResourceSpec(Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
WorkerResourceSpec |
MesosWorkerResourceSpecFactory.createDefaultWorkerResourceSpec(Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
boolean |
MesosResourceManager.startNewWorker(WorkerResourceSpec workerResourceSpec) |
Modifier and Type | Method and Description |
---|---|
WorkerResourceSpec |
MesosWorkerStore.Worker.workerResourceSpec()
Get the worker request associated with the worker.
|
Modifier and Type | Method and Description |
---|---|
static MesosWorkerStore.Worker |
MesosWorkerStore.Worker.newWorker(org.apache.mesos.Protos.TaskID taskID,
WorkerResourceSpec workerResourceSpec)
Create a new worker with the given taskID.
|
Modifier and Type | Method and Description |
---|---|
static TaskExecutorProcessSpec |
TaskExecutorProcessUtils.processSpecFromWorkerResourceSpec(Configuration config,
WorkerResourceSpec workerResourceSpec) |
Modifier and Type | Field and Description |
---|---|
static WorkerResourceSpec |
WorkerResourceSpec.ZERO |
Modifier and Type | Method and Description |
---|---|
WorkerResourceSpec |
WorkerResourceSpec.Builder.build() |
WorkerResourceSpec |
ArbitraryWorkerResourceSpecFactory.createDefaultWorkerResourceSpec(Configuration configuration) |
abstract WorkerResourceSpec |
WorkerResourceSpecFactory.createDefaultWorkerResourceSpec(Configuration configuration) |
static WorkerResourceSpec |
WorkerResourceSpec.fromTaskExecutorProcessSpec(TaskExecutorProcessSpec taskExecutorProcessSpec) |
protected WorkerResourceSpec |
WorkerResourceSpecFactory.workerResourceSpecFromConfigAndCpu(Configuration configuration,
CPUResource cpuResource) |
Modifier and Type | Method and Description |
---|---|
protected Map<WorkerResourceSpec,Integer> |
ResourceManager.getRequiredResources() |
Modifier and Type | Method and Description |
---|---|
protected int |
ActiveResourceManager.getNumRequestedNotAllocatedWorkersFor(WorkerResourceSpec workerResourceSpec) |
protected int |
ActiveResourceManager.getNumRequestedNotRegisteredWorkersFor(WorkerResourceSpec workerResourceSpec) |
protected ActiveResourceManager.PendingWorkerNums |
ActiveResourceManager.notifyNewWorkerAllocated(WorkerResourceSpec workerResourceSpec,
ResourceID resourceID)
Notify that a worker with the given resource spec has been allocated.
|
protected ActiveResourceManager.PendingWorkerNums |
ActiveResourceManager.notifyNewWorkerAllocationFailed(WorkerResourceSpec workerResourceSpec)
Notify that allocation of a worker with the given resource spec has failed.
|
protected ActiveResourceManager.PendingWorkerNums |
ActiveResourceManager.notifyNewWorkerRequested(WorkerResourceSpec workerResourceSpec)
Notify that a worker with the given resource spec has been requested.
|
boolean |
StandaloneResourceManager.startNewWorker(WorkerResourceSpec workerResourceSpec) |
abstract boolean |
ResourceManager.startNewWorker(WorkerResourceSpec workerResourceSpec)
Allocates a resource using the worker resource specification.
|
Modifier and Type | Method and Description |
---|---|
WorkerResourceSpec |
SlotManagerConfiguration.getDefaultWorkerResourceSpec() |
Modifier and Type | Method and Description |
---|---|
Map<WorkerResourceSpec,Integer> |
SlotManager.getRequiredResources()
Get number of workers SlotManager requested from
ResourceActions that are not yet
fulfilled. |
Map<WorkerResourceSpec,Integer> |
SlotManagerImpl.getRequiredResources() |
Modifier and Type | Method and Description |
---|---|
boolean |
ResourceActions.allocateResource(WorkerResourceSpec workerResourceSpec)
Requests to allocate a resource with the given
WorkerResourceSpec . |
static SlotManagerConfiguration |
SlotManagerConfiguration.fromConfiguration(Configuration configuration,
WorkerResourceSpec defaultWorkerResourceSpec) |
static ResourceProfile |
SlotManagerImpl.generateDefaultSlotResourceProfile(WorkerResourceSpec workerResourceSpec,
int numSlotsPerWorker) |
Constructor and Description |
---|
SlotManagerConfiguration(Time taskManagerRequestTimeout,
Time slotRequestTimeout,
Time taskManagerTimeout,
boolean waitResultConsumedBeforeRelease,
SlotMatchingStrategy slotMatchingStrategy,
WorkerResourceSpec defaultWorkerResourceSpec,
int numSlotsPerWorker,
int maxSlotNum) |
Modifier and Type | Method and Description |
---|---|
boolean |
YarnResourceManager.startNewWorker(WorkerResourceSpec workerResourceSpec) |
Modifier and Type | Method and Description |
---|---|
WorkerResourceSpec |
YarnWorkerResourceSpecFactory.createDefaultWorkerResourceSpec(Configuration configuration) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.