Package org.apache.flink.runtime.clusterframework.types

Class ResourceProfile.Builder

java.lang.Object

org.apache.flink.runtime.clusterframework.types.ResourceProfile.Builder

Enclosing class:

ResourceProfile

public static class ResourceProfile.Builder
extends Object

Builder for the ResourceProfile.

Method Summary

Modifier and Type	Method	Description
ResourceProfile	build()
ResourceProfile.Builder	setCpuCores(double cpuCores)
ResourceProfile.Builder	setCpuCores(CPUResource cpuCores)
ResourceProfile.Builder	setExtendedResource(ExternalResource extendedResource)	Add the given extended resource.
ResourceProfile.Builder	setExtendedResources(Collection<ExternalResource> extendedResources)	Add the given extended resources.
ResourceProfile.Builder	setManagedMemory(MemorySize managedMemory)
ResourceProfile.Builder	setManagedMemoryMB(int managedMemoryMB)
ResourceProfile.Builder	setNetworkMemory(MemorySize networkMemory)
ResourceProfile.Builder	setNetworkMemoryMB(int networkMemoryMB)
ResourceProfile.Builder	setTaskHeapMemory(MemorySize taskHeapMemory)
ResourceProfile.Builder	setTaskHeapMemoryMB(int taskHeapMemoryMB)
ResourceProfile.Builder	setTaskOffHeapMemory(MemorySize taskOffHeapMemory)
ResourceProfile.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 ResourceProfile.Builder setCpuCores(CPUResource cpuCores)

setCpuCores

public ResourceProfile.Builder setCpuCores(double cpuCores)

setTaskHeapMemory

public ResourceProfile.Builder setTaskHeapMemory(MemorySize taskHeapMemory)

setTaskHeapMemoryMB

public ResourceProfile.Builder setTaskHeapMemoryMB(int taskHeapMemoryMB)

setTaskOffHeapMemory

public ResourceProfile.Builder setTaskOffHeapMemory(MemorySize taskOffHeapMemory)

setTaskOffHeapMemoryMB

public ResourceProfile.Builder setTaskOffHeapMemoryMB(int taskOffHeapMemoryMB)

setManagedMemory

public ResourceProfile.Builder setManagedMemory(MemorySize managedMemory)

setManagedMemoryMB

public ResourceProfile.Builder setManagedMemoryMB(int managedMemoryMB)

setNetworkMemory

public ResourceProfile.Builder setNetworkMemory(MemorySize networkMemory)

setNetworkMemoryMB

public ResourceProfile.Builder setNetworkMemoryMB(int networkMemoryMB)

setExtendedResource

public ResourceProfile.Builder setExtendedResource(ExternalResource extendedResource)

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

setExtendedResources

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

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

build

public ResourceProfile build()