org.apache.flink.api.common.operators

Class SlotSharingGroup.Builder

java.lang.Object

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

Enclosing class:

SlotSharingGroup

public static class SlotSharingGroup.Builder
extends Object

Builder for the SlotSharingGroup.

Method Summary

Modifier and Type	Method and Description
SlotSharingGroup	build() Build the SlotSharingGroup.
SlotSharingGroup.Builder	setCpuCores(double cpuCores) Set the CPU cores for this SlotSharingGroup.
SlotSharingGroup.Builder	setExternalResource(String name, double value) Add the given external resource.
SlotSharingGroup.Builder	setManagedMemory(MemorySize managedMemory) Set the task managed memory for this SlotSharingGroup.
SlotSharingGroup.Builder	setManagedMemoryMB(int managedMemoryMB) Set the task managed memory for this SlotSharingGroup in MB.
SlotSharingGroup.Builder	setTaskHeapMemory(MemorySize taskHeapMemory) Set the task heap memory for this SlotSharingGroup.
SlotSharingGroup.Builder	setTaskHeapMemoryMB(int taskHeapMemoryMB) Set the task heap memory for this SlotSharingGroup in MB.
SlotSharingGroup.Builder	setTaskOffHeapMemory(MemorySize taskOffHeapMemory) Set the task off-heap memory for this SlotSharingGroup.
SlotSharingGroup.Builder	setTaskOffHeapMemoryMB(int taskOffHeapMemoryMB) Set the task off-heap memory for this SlotSharingGroup in MB.

Methods inherited from class java.lang.Object

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

Method Detail

setCpuCores

public SlotSharingGroup.Builder setCpuCores(double cpuCores)

Set the CPU cores for this SlotSharingGroup.

setTaskHeapMemory

public SlotSharingGroup.Builder setTaskHeapMemory(MemorySize taskHeapMemory)

Set the task heap memory for this SlotSharingGroup.

setTaskHeapMemoryMB

public SlotSharingGroup.Builder setTaskHeapMemoryMB(int taskHeapMemoryMB)

Set the task heap memory for this SlotSharingGroup in MB.

setTaskOffHeapMemory

public SlotSharingGroup.Builder setTaskOffHeapMemory(MemorySize taskOffHeapMemory)

Set the task off-heap memory for this SlotSharingGroup.

setTaskOffHeapMemoryMB

public SlotSharingGroup.Builder setTaskOffHeapMemoryMB(int taskOffHeapMemoryMB)

Set the task off-heap memory for this SlotSharingGroup in MB.

setManagedMemory

public SlotSharingGroup.Builder setManagedMemory(MemorySize managedMemory)

Set the task managed memory for this SlotSharingGroup.

setManagedMemoryMB

public SlotSharingGroup.Builder setManagedMemoryMB(int managedMemoryMB)

Set the task managed memory for this SlotSharingGroup in MB.

setExternalResource

public SlotSharingGroup.Builder setExternalResource(String name,
                                                    double value)

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

build

public SlotSharingGroup build()

Build the SlotSharingGroup.