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 and Description
ResourceProfile.Builder	addExtendedResource(String name, Resource extendedResource)
ResourceProfile.Builder	addExtendedResources(Map<String,Resource> extendedResources)
ResourceProfile	build()
ResourceProfile.Builder	setCpuCores(double cpuCores)
ResourceProfile.Builder	setCpuCores(Resource cpuCores)
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(Resource 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)

addExtendedResource

public ResourceProfile.Builder addExtendedResource(String name,
                                                   Resource extendedResource)

addExtendedResources

public ResourceProfile.Builder addExtendedResources(Map<String,Resource> extendedResources)

build

public ResourceProfile build()