org.apache.flink.runtime.taskexecutor

Class TaskExecutorResourceSpec

java.lang.Object

org.apache.flink.runtime.taskexecutor.TaskExecutorResourceSpec

public class TaskExecutorResourceSpec
extends Object

Specification of resources to use in running TaskExecutor.

Constructor Summary

Constructors

Constructor and Description
TaskExecutorResourceSpec(CPUResource cpuCores, MemorySize taskHeapSize, MemorySize taskOffHeapSize, MemorySize networkMemSize, MemorySize managedMemorySize, Collection<ExternalResource> extendedResources)

Method Summary

Modifier and Type	Method and Description
CPUResource	getCpuCores()
Map<String,ExternalResource>	getExtendedResources()
MemorySize	getManagedMemorySize()
MemorySize	getNetworkMemSize()
MemorySize	getTaskHeapSize()
MemorySize	getTaskOffHeapSize()

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskExecutorResourceSpec

public TaskExecutorResourceSpec(CPUResource cpuCores,
                                MemorySize taskHeapSize,
                                MemorySize taskOffHeapSize,
                                MemorySize networkMemSize,
                                MemorySize managedMemorySize,
                                Collection<ExternalResource> extendedResources)

Method Detail

getCpuCores

public CPUResource getCpuCores()

getTaskHeapSize

public MemorySize getTaskHeapSize()

getTaskOffHeapSize

public MemorySize getTaskOffHeapSize()

getNetworkMemSize

public MemorySize getNetworkMemSize()

getManagedMemorySize

public MemorySize getManagedMemorySize()

getExtendedResources

public Map<String,ExternalResource> getExtendedResources()