Package | Description |
---|---|
org.apache.flink.api.common.operators | |
org.apache.flink.configuration | |
org.apache.flink.contrib.streaming.state | |
org.apache.flink.runtime.clusterframework |
This package contains the cluster resource management functionality.
|
org.apache.flink.runtime.clusterframework.types | |
org.apache.flink.runtime.shuffle | |
org.apache.flink.runtime.taskexecutor | |
org.apache.flink.runtime.taskmanager | |
org.apache.flink.table.descriptors | |
org.apache.flink.test.util |
Modifier and Type | Method and Description |
---|---|
MemorySize |
ResourceSpec.getManagedMemory() |
MemorySize |
ResourceSpec.getTaskHeapMemory() |
MemorySize |
ResourceSpec.getTaskOffHeapMemory() |
Modifier and Type | Method and Description |
---|---|
ResourceSpec.Builder |
ResourceSpec.Builder.setManagedMemory(MemorySize managedMemory) |
ResourceSpec.Builder |
ResourceSpec.Builder.setTaskHeapMemory(MemorySize taskHeapMemory) |
ResourceSpec.Builder |
ResourceSpec.Builder.setTaskOffHeapMemory(MemorySize taskOffHeapMemory) |
Modifier and Type | Field and Description |
---|---|
static MemorySize |
MemorySize.MAX_VALUE |
static MemorySize |
MemorySize.ZERO |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<MemorySize> |
TaskManagerOptions.FRAMEWORK_HEAP_MEMORY
Framework Heap Memory size for TaskExecutors.
|
static ConfigOption<MemorySize> |
TaskManagerOptions.FRAMEWORK_OFF_HEAP_MEMORY
Framework Off-Heap Memory size for TaskExecutors.
|
static ConfigOption<MemorySize> |
TaskManagerOptions.JVM_METASPACE
JVM Metaspace Size for the TaskExecutors.
|
static ConfigOption<MemorySize> |
TaskManagerOptions.JVM_OVERHEAD_MAX
Max JVM Overhead size for the TaskExecutors.
|
static ConfigOption<MemorySize> |
TaskManagerOptions.JVM_OVERHEAD_MIN
Min JVM Overhead size for the TaskExecutors.
|
static ConfigOption<MemorySize> |
TaskManagerOptions.MANAGED_MEMORY_SIZE
Managed Memory size for TaskExecutors.
|
static ConfigOption<MemorySize> |
TaskManagerOptions.MEMORY_SEGMENT_SIZE
Size of memory buffers used by the network stack and the memory manager.
|
static ConfigOption<MemorySize> |
TaskManagerOptions.NETWORK_MEMORY_MAX
Max Network Memory size for TaskExecutors.
|
static ConfigOption<MemorySize> |
TaskManagerOptions.NETWORK_MEMORY_MIN
Min Network Memory size for TaskExecutors.
|
static ConfigOption<MemorySize> |
TaskManagerOptions.TASK_HEAP_MEMORY
Task Heap Memory size for TaskExecutors.
|
static ConfigOption<MemorySize> |
TaskManagerOptions.TASK_MANAGER_HEAP_MEMORY
Deprecated.
use
TaskManagerOptions.TOTAL_FLINK_MEMORY for standalone setups and TaskManagerOptions.TOTAL_PROCESS_MEMORY for containerized setups. |
static ConfigOption<MemorySize> |
TaskManagerOptions.TASK_OFF_HEAP_MEMORY
Task Off-Heap Memory size for TaskExecutors.
|
static ConfigOption<MemorySize> |
TaskManagerOptions.TOTAL_FLINK_MEMORY
Total Flink Memory size for the TaskExecutors.
|
static ConfigOption<MemorySize> |
TaskManagerOptions.TOTAL_PROCESS_MEMORY
Total Process Memory size for the TaskExecutors.
|
Modifier and Type | Method and Description |
---|---|
MemorySize |
MemorySize.add(MemorySize that) |
MemorySize |
MemorySize.divide(long by) |
static MemorySize |
ConfigurationUtils.getJobManagerHeapMemory(Configuration configuration)
Get job manager's heap memory.
|
MemorySize |
MemorySize.multiply(double multiplier) |
static MemorySize |
MemorySize.ofMebiBytes(long mebiBytes) |
static MemorySize |
MemorySize.parse(String text)
Parses the given string as as MemorySize.
|
static MemorySize |
MemorySize.parse(String text,
MemorySize.MemoryUnit defaultUnit)
Parses the given string with a default unit.
|
MemorySize |
MemorySize.subtract(MemorySize that) |
Modifier and Type | Method and Description |
---|---|
ConfigOptions.TypedConfigOptionBuilder<MemorySize> |
ConfigOptions.OptionBuilder.memoryType()
Defines that the value of the option should be of
MemorySize type. |
Modifier and Type | Method and Description |
---|---|
MemorySize |
MemorySize.add(MemorySize that) |
int |
MemorySize.compareTo(MemorySize that) |
MemorySize |
MemorySize.subtract(MemorySize that) |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<MemorySize> |
RocksDBConfigurableOptions.BLOCK_CACHE_SIZE |
static ConfigOption<MemorySize> |
RocksDBConfigurableOptions.BLOCK_SIZE |
static ConfigOption<MemorySize> |
RocksDBOptions.FIX_PER_SLOT_MEMORY_SIZE |
static ConfigOption<MemorySize> |
RocksDBConfigurableOptions.MAX_SIZE_LEVEL_BASE |
static ConfigOption<MemorySize> |
RocksDBConfigurableOptions.TARGET_FILE_SIZE_BASE |
static ConfigOption<MemorySize> |
RocksDBConfigurableOptions.WRITE_BATCH_SIZE |
static ConfigOption<MemorySize> |
RocksDBConfigurableOptions.WRITE_BUFFER_SIZE |
Modifier and Type | Method and Description |
---|---|
MemorySize |
RocksDBMemoryConfiguration.getFixedMemoryPerSlot()
Gets the fixed amount of memory to be shared between all RocksDB instances (in all tasks and
operators) of a slot.
|
Modifier and Type | Method and Description |
---|---|
void |
RocksDBMemoryConfiguration.setFixedMemoryPerSlot(MemorySize fixedMemoryPerSlot)
Configures RocksDB to use a fixed amount of memory shared between all instances (operators) in a slot.
|
Modifier and Type | Method and Description |
---|---|
MemorySize |
TaskExecutorProcessSpec.getFrameworkHeapSize() |
MemorySize |
TaskExecutorProcessSpec.getFrameworkOffHeapMemorySize() |
MemorySize |
TaskExecutorProcessSpec.getJvmDirectMemorySize() |
MemorySize |
TaskExecutorProcessSpec.getJvmHeapMemorySize() |
MemorySize |
TaskExecutorProcessSpec.getJvmMetaspaceSize() |
MemorySize |
TaskExecutorProcessSpec.getJvmOverheadSize() |
MemorySize |
TaskExecutorProcessSpec.getManagedMemorySize() |
MemorySize |
TaskExecutorProcessSpec.getNetworkMemSize() |
MemorySize |
TaskExecutorProcessSpec.getTaskHeapSize() |
MemorySize |
TaskExecutorProcessSpec.getTaskOffHeapSize() |
MemorySize |
TaskExecutorProcessSpec.getTotalFlinkMemorySize() |
MemorySize |
TaskExecutorProcessSpec.getTotalProcessMemorySize() |
Modifier and Type | Method and Description |
---|---|
TaskExecutorProcessSpecBuilder |
TaskExecutorProcessSpecBuilder.withTotalProcessMemory(MemorySize totalProcessMemory) |
Modifier and Type | Method and Description |
---|---|
static Configuration |
TaskExecutorProcessUtils.getConfigurationMapLegacyTaskManagerHeapSizeToConfigOption(Configuration configuration,
ConfigOption<MemorySize> configOption) |
Constructor and Description |
---|
TaskExecutorProcessSpec(CPUResource cpuCores,
MemorySize frameworkHeapSize,
MemorySize frameworkOffHeapSize,
MemorySize taskHeapSize,
MemorySize taskOffHeapSize,
MemorySize networkMemSize,
MemorySize managedMemorySize,
MemorySize jvmMetaspaceSize,
MemorySize jvmOverheadSize) |
Modifier and Type | Method and Description |
---|---|
MemorySize |
ResourceProfile.getManagedMemory()
Get the managed memory needed.
|
MemorySize |
ResourceProfile.getNetworkMemory()
Get the network memory needed.
|
MemorySize |
ResourceProfile.getOperatorsMemory()
Get the memory the operators needed.
|
MemorySize |
ResourceProfile.getTaskHeapMemory()
Get the task heap memory needed.
|
MemorySize |
ResourceProfile.getTaskOffHeapMemory()
Get the task off-heap memory needed.
|
MemorySize |
ResourceProfile.getTotalMemory()
Get the total memory needed.
|
Modifier and Type | Method and Description |
---|---|
static ResourceProfile |
ResourceProfile.fromResourceSpec(ResourceSpec resourceSpec,
MemorySize networkMemory) |
ResourceProfile.Builder |
ResourceProfile.Builder.setManagedMemory(MemorySize managedMemory) |
ResourceProfile.Builder |
ResourceProfile.Builder.setNetworkMemory(MemorySize networkMemory) |
ResourceProfile.Builder |
ResourceProfile.Builder.setTaskHeapMemory(MemorySize taskHeapMemory) |
ResourceProfile.Builder |
ResourceProfile.Builder.setTaskOffHeapMemory(MemorySize taskOffHeapMemory) |
Modifier and Type | Method and Description |
---|---|
MemorySize |
ShuffleEnvironmentContext.getNetworkMemorySize() |
Constructor and Description |
---|
ShuffleEnvironmentContext(Configuration configuration,
ResourceID taskExecutorResourceId,
MemorySize networkMemorySize,
boolean localCommunicationOnly,
InetAddress hostAddress,
TaskEventPublisher eventPublisher,
MetricGroup parentMetricGroup,
Executor ioExecutor) |
Modifier and Type | Method and Description |
---|---|
MemorySize |
TaskExecutorResourceSpec.getManagedMemorySize() |
MemorySize |
TaskManagerServicesConfiguration.getManagedMemorySize() |
MemorySize |
TaskManagerServicesConfiguration.getNetworkMemorySize() |
MemorySize |
TaskExecutorResourceSpec.getNetworkMemSize() |
MemorySize |
TaskExecutorResourceSpec.getTaskHeapSize() |
MemorySize |
TaskExecutorResourceSpec.getTaskOffHeapSize() |
Constructor and Description |
---|
TaskExecutorResourceSpec(CPUResource cpuCores,
MemorySize taskHeapSize,
MemorySize taskOffHeapSize,
MemorySize networkMemSize,
MemorySize managedMemorySize) |
Modifier and Type | Method and Description |
---|---|
static NettyShuffleEnvironmentConfiguration |
NettyShuffleEnvironmentConfiguration.fromConfiguration(Configuration configuration,
MemorySize networkMemorySize,
boolean localTaskManagerCommunication,
InetAddress taskManagerAddress)
Utility method to extract network related parameters from the configuration and to
sanity check them.
|
Modifier and Type | Method and Description |
---|---|
MemorySize |
DescriptorProperties.getMemorySize(String key)
Returns a Flink
MemorySize under the given existing key. |
Modifier and Type | Method and Description |
---|---|
Optional<MemorySize> |
DescriptorProperties.getOptionalMemorySize(String key)
Returns a Flink
MemorySize under the given key if it exists. |
Modifier and Type | Method and Description |
---|---|
void |
DescriptorProperties.putMemorySize(String key,
MemorySize size)
Adds a Flink
MemorySize under the given key. |
Modifier and Type | Method and Description |
---|---|
TestProcessBuilder |
TestProcessBuilder.setJvmMemory(MemorySize jvmMemory) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.