Package | Description |
---|---|
org.apache.flink.api.common.operators | |
org.apache.flink.api.common.resources | |
org.apache.flink.runtime.clusterframework.types |
Modifier and Type | Method and Description |
---|---|
Resource |
ResourceSpec.getCpuCores() |
Resource |
ResourceSpec.getGPUResource() |
Modifier and Type | Method and Description |
---|---|
Map<String,Resource> |
ResourceSpec.getExtendedResources() |
Modifier and Type | Class and Description |
---|---|
class |
CPUResource
Represents CPU resource.
|
class |
GPUResource
The GPU resource.
|
Modifier and Type | Method and Description |
---|---|
Resource |
GPUResource.create(BigDecimal value) |
protected abstract Resource |
Resource.create(BigDecimal value)
Create a new instance of the sub resource.
|
Resource |
CPUResource.create(BigDecimal value) |
Resource |
Resource.divide(BigDecimal by) |
Resource |
Resource.divide(int by) |
Resource |
Resource.merge(Resource other) |
Resource |
Resource.multiply(BigDecimal multiplier) |
Resource |
Resource.multiply(int multiplier) |
Resource |
Resource.subtract(Resource other) |
Modifier and Type | Method and Description |
---|---|
Resource |
Resource.merge(Resource other) |
Resource |
Resource.subtract(Resource other) |
Modifier and Type | Method and Description |
---|---|
Resource |
ResourceProfile.getCpuCores()
Get the cpu cores needed.
|
Modifier and Type | Method and Description |
---|---|
Map<String,Resource> |
ResourceProfile.getExtendedResources()
Get the extended resources.
|
Modifier and Type | Method and Description |
---|---|
ResourceProfile.Builder |
ResourceProfile.Builder.addExtendedResource(String name,
Resource extendedResource) |
ResourceProfile.Builder |
ResourceProfile.Builder.setCpuCores(Resource cpuCores) |
Modifier and Type | Method and Description |
---|---|
ResourceProfile.Builder |
ResourceProfile.Builder.addExtendedResources(Map<String,Resource> extendedResources) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.