Package org.apache.flink.api.common.operators

Class ResourceSpec.Builder

java.lang.Object

org.apache.flink.api.common.operators.ResourceSpec.Builder

Enclosing class:

ResourceSpec

public static class ResourceSpec.Builder
extends Object

Builder for the ResourceSpec.

Method Summary

Modifier and Type	Method	Description
ResourceSpec	build()
ResourceSpec.Builder	setCpuCores(double cpuCores)
ResourceSpec.Builder	setExtendedResource(ExternalResource extendedResource)	Add the given extended resource.
ResourceSpec.Builder	setExtendedResources(Collection<ExternalResource> extendedResources)	Add the given extended resources.
ResourceSpec.Builder	setManagedMemory(org.apache.flink.configuration.MemorySize managedMemory)
ResourceSpec.Builder	setManagedMemoryMB(int managedMemoryMB)
ResourceSpec.Builder	setTaskHeapMemory(org.apache.flink.configuration.MemorySize taskHeapMemory)
ResourceSpec.Builder	setTaskHeapMemoryMB(int taskHeapMemoryMB)
ResourceSpec.Builder	setTaskOffHeapMemory(org.apache.flink.configuration.MemorySize taskOffHeapMemory)
ResourceSpec.Builder	setTaskOffHeapMemoryMB(int taskOffHeapMemoryMB)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

setCpuCores

public ResourceSpec.Builder setCpuCores(double cpuCores)

setTaskHeapMemory

public ResourceSpec.Builder setTaskHeapMemory(org.apache.flink.configuration.MemorySize taskHeapMemory)

setTaskHeapMemoryMB

public ResourceSpec.Builder setTaskHeapMemoryMB(int taskHeapMemoryMB)

setTaskOffHeapMemory

public ResourceSpec.Builder setTaskOffHeapMemory(org.apache.flink.configuration.MemorySize taskOffHeapMemory)

setTaskOffHeapMemoryMB

public ResourceSpec.Builder setTaskOffHeapMemoryMB(int taskOffHeapMemoryMB)

setManagedMemory

public ResourceSpec.Builder setManagedMemory(org.apache.flink.configuration.MemorySize managedMemory)

setManagedMemoryMB

public ResourceSpec.Builder setManagedMemoryMB(int managedMemoryMB)

setExtendedResource

public ResourceSpec.Builder setExtendedResource(ExternalResource extendedResource)

Add the given extended resource. The old value with the same resource name will be replaced if present.

setExtendedResources

public ResourceSpec.Builder setExtendedResources(Collection<ExternalResource> extendedResources)

Add the given extended resources. This will discard all the previous added extended resources.

build

public ResourceSpec build()