Package | Description |
---|---|
org.apache.flink.api.common.operators | |
org.apache.flink.api.common.resources | |
org.apache.flink.kubernetes.kubeclient.parameters | |
org.apache.flink.kubernetes.utils | |
org.apache.flink.runtime.clusterframework |
This package contains the cluster resource management functionality.
|
org.apache.flink.runtime.clusterframework.types | |
org.apache.flink.runtime.externalresource | |
org.apache.flink.runtime.resourcemanager | |
org.apache.flink.runtime.taskexecutor |
Modifier and Type | Method and Description |
---|---|
Optional<ExternalResource> |
ResourceSpec.getExtendedResource(String name) |
Map<String,ExternalResource> |
ResourceSpec.getExtendedResources() |
Modifier and Type | Method and Description |
---|---|
ResourceSpec.Builder |
ResourceSpec.Builder.setExtendedResource(ExternalResource extendedResource)
Add the given extended resource.
|
Modifier and Type | Method and Description |
---|---|
ResourceSpec.Builder |
ResourceSpec.Builder.setExtendedResources(Collection<ExternalResource> extendedResources)
Add the given extended resources.
|
Modifier and Type | Method and Description |
---|---|
protected ExternalResource |
ExternalResource.create(BigDecimal value) |
Modifier and Type | Method and Description |
---|---|
Map<String,ExternalResource> |
KubernetesTaskManagerParameters.getTaskManagerExternalResources() |
Modifier and Type | Method and Description |
---|---|
static io.fabric8.kubernetes.api.model.ResourceRequirements |
KubernetesUtils.getResourceRequirements(io.fabric8.kubernetes.api.model.ResourceRequirements resourceRequirements,
int mem,
double memoryLimitFactor,
double cpu,
double cpuLimitFactor,
Map<String,ExternalResource> externalResources,
Map<String,String> externalResourceConfigKeys)
Get resource requirements from memory and cpu.
|
Modifier and Type | Method and Description |
---|---|
Map<String,ExternalResource> |
TaskExecutorProcessSpec.getExtendedResources() |
Constructor and Description |
---|
TaskExecutorProcessSpec(CPUResource cpuCores,
MemorySize frameworkHeapSize,
MemorySize frameworkOffHeapSize,
MemorySize taskHeapSize,
MemorySize taskOffHeapSize,
MemorySize networkMemSize,
MemorySize managedMemorySize,
MemorySize jvmMetaspaceSize,
MemorySize jvmOverheadSize,
Collection<ExternalResource> extendedResources) |
TaskExecutorProcessSpec(CPUResource cpuCores,
TaskExecutorFlinkMemory flinkMemory,
JvmMetaspaceAndOverhead jvmMetaspaceAndOverhead,
int numSlots,
Collection<ExternalResource> extendedResources) |
Modifier and Type | Method and Description |
---|---|
Map<String,ExternalResource> |
ResourceProfile.getExtendedResources()
Get the extended resources.
|
Modifier and Type | Method and Description |
---|---|
ResourceProfile.Builder |
ResourceProfile.Builder.setExtendedResource(ExternalResource extendedResource)
Add the given extended resource.
|
Modifier and Type | Method and Description |
---|---|
ResourceProfile.Builder |
ResourceProfile.Builder.setExtendedResources(Collection<ExternalResource> extendedResources)
Add the given extended resources.
|
Modifier and Type | Method and Description |
---|---|
static Collection<ExternalResource> |
ExternalResourceUtils.getExternalResourcesCollection(Configuration config)
Get the collection of all enabled external resources.
|
Modifier and Type | Method and Description |
---|---|
static String |
ExternalResourceUtils.generateExternalResourcesString(Collection<ExternalResource> extendedResources)
Generate the string expression of the given external resources.
|
Modifier and Type | Method and Description |
---|---|
Map<String,ExternalResource> |
WorkerResourceSpec.getExtendedResources() |
Modifier and Type | Method and Description |
---|---|
WorkerResourceSpec.Builder |
WorkerResourceSpec.Builder.setExtendedResource(ExternalResource extendedResource)
Add the given extended resource.
|
Modifier and Type | Method and Description |
---|---|
WorkerResourceSpec.Builder |
WorkerResourceSpec.Builder.setExtendedResources(Collection<ExternalResource> extendedResources)
Add the given extended resources.
|
Modifier and Type | Method and Description |
---|---|
Map<String,ExternalResource> |
TaskExecutorResourceSpec.getExtendedResources() |
Constructor and Description |
---|
TaskExecutorResourceSpec(CPUResource cpuCores,
MemorySize taskHeapSize,
MemorySize taskOffHeapSize,
MemorySize networkMemSize,
MemorySize managedMemorySize,
Collection<ExternalResource> extendedResources) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.