Uses of Class
org.apache.flink.configuration.MemorySize
-
Packages that use MemorySize Package Description org.apache.flink.api.common.operators org.apache.flink.configuration -
-
Uses of MemorySize in org.apache.flink.api.common.operators
Methods in org.apache.flink.api.common.operators that return MemorySize Modifier and Type Method Description MemorySizeResourceSpec. getManagedMemory()MemorySizeResourceSpec. getTaskHeapMemory()MemorySizeResourceSpec. getTaskOffHeapMemory()Methods in org.apache.flink.api.common.operators that return types with arguments of type MemorySize Modifier and Type Method Description Optional<MemorySize>SlotSharingGroup. getManagedMemory()Optional<MemorySize>SlotSharingGroup. getTaskHeapMemory()Optional<MemorySize>SlotSharingGroup. getTaskOffHeapMemory()Methods in org.apache.flink.api.common.operators with parameters of type MemorySize Modifier and Type Method Description static ResourceSpec.BuilderResourceSpec. newBuilder(double cpuCores, MemorySize taskHeapMemory)ResourceSpec.BuilderResourceSpec.Builder. setManagedMemory(MemorySize managedMemory)SlotSharingGroup.BuilderSlotSharingGroup.Builder. setManagedMemory(MemorySize managedMemory)Set the task managed memory for this SlotSharingGroup.ResourceSpec.BuilderResourceSpec.Builder. setTaskHeapMemory(MemorySize taskHeapMemory)SlotSharingGroup.BuilderSlotSharingGroup.Builder. setTaskHeapMemory(MemorySize taskHeapMemory)Set the task heap memory for this SlotSharingGroup.ResourceSpec.BuilderResourceSpec.Builder. setTaskOffHeapMemory(MemorySize taskOffHeapMemory)SlotSharingGroup.BuilderSlotSharingGroup.Builder. setTaskOffHeapMemory(MemorySize taskOffHeapMemory)Set the task off-heap memory for this SlotSharingGroup. -
Uses of MemorySize in org.apache.flink.configuration
Fields in org.apache.flink.configuration declared as MemorySize Modifier and Type Field Description static MemorySizeMemorySize. MAX_VALUEstatic MemorySizeJobManagerOptions. MIN_JVM_HEAP_SIZEstatic MemorySizeMemorySize. ZEROFields in org.apache.flink.configuration with type parameters of type MemorySize Modifier and Type Field Description static ConfigOption<MemorySize>BatchExecutionOptions. ADAPTIVE_AUTO_PARALLELISM_AVG_DATA_VOLUME_PER_TASKstatic ConfigOption<MemorySize>JobManagerOptions. ADAPTIVE_BATCH_SCHEDULER_AVG_DATA_VOLUME_PER_TASKstatic ConfigOption<MemorySize>TaskManagerOptions. FRAMEWORK_HEAP_MEMORYFramework Heap Memory size for TaskExecutors.static ConfigOption<MemorySize>TaskManagerOptions. FRAMEWORK_OFF_HEAP_MEMORYFramework Off-Heap Memory size for TaskExecutors.static ConfigOption<MemorySize>CheckpointingOptions. FS_SMALL_FILE_THRESHOLDThe minimum size of state data files.static ConfigOption<MemorySize>JobManagerOptions. JOB_MANAGER_HEAP_MEMORYDeprecated.useJobManagerOptions.TOTAL_FLINK_MEMORYfor standalone setups andJobManagerOptions.TOTAL_PROCESS_MEMORYfor containerized setups.static ConfigOption<MemorySize>JobManagerOptions. JVM_HEAP_MEMORYJVM Heap Memory size for the JobManager.static ConfigOption<MemorySize>JobManagerOptions. JVM_METASPACEJVM Metaspace Size for the JobManager.static ConfigOption<MemorySize>TaskManagerOptions. JVM_METASPACEJVM Metaspace Size for the TaskExecutors.static ConfigOption<MemorySize>JobManagerOptions. JVM_OVERHEAD_MAXMax JVM Overhead size for the TaskExecutors.static ConfigOption<MemorySize>TaskManagerOptions. JVM_OVERHEAD_MAXMax JVM Overhead size for the TaskExecutors.static ConfigOption<MemorySize>JobManagerOptions. JVM_OVERHEAD_MINMin JVM Overhead size for the JobManager.static ConfigOption<MemorySize>TaskManagerOptions. JVM_OVERHEAD_MINMin JVM Overhead size for the TaskExecutors.static ConfigOption<MemorySize>TaskManagerOptions. MANAGED_MEMORY_SIZEManaged Memory size for TaskExecutors.static ConfigOption<MemorySize>ResourceManagerOptions. MAX_TOTAL_MEMstatic ConfigOption<MemorySize>TaskManagerOptions. MEMORY_SEGMENT_SIZESize of memory buffers used by the network stack and the memory manager.static ConfigOption<MemorySize>TaskManagerOptions. MIN_MEMORY_SEGMENT_SIZEMinimum possible size of memory buffers used by the network stack and the memory manager.static ConfigOption<MemorySize>ResourceManagerOptions. MIN_TOTAL_MEMstatic ConfigOption<MemorySize>TaskManagerOptions. NETWORK_BATCH_SHUFFLE_READ_MEMORYSize of direct memory used by batch shuffle for shuffle data read (currently only used by sort-shuffle and hybrid shuffle).static ConfigOption<MemorySize>TaskManagerOptions. NETWORK_MEMORY_MAXMax Network Memory size for TaskExecutors.static ConfigOption<MemorySize>TaskManagerOptions. NETWORK_MEMORY_MINMin Network Memory size for TaskExecutors.static ConfigOption<MemorySize>JobManagerOptions. OFF_HEAP_MEMORYOff-heap Memory size for the JobManager.static ConfigOption<MemorySize>ExecutionOptions. SORTED_INPUTS_MEMORYstatic ConfigOption<MemorySize>TaskManagerOptions. TASK_HEAP_MEMORYTask Heap Memory size for TaskExecutors.static ConfigOption<MemorySize>TaskManagerOptions. TASK_MANAGER_HEAP_MEMORYDeprecated.useTaskManagerOptions.TOTAL_FLINK_MEMORYfor standalone setups andTaskManagerOptions.TOTAL_PROCESS_MEMORYfor containerized setups.static ConfigOption<MemorySize>TaskManagerOptions. TASK_MANAGER_SYSTEM_OUT_LOG_CACHE_SIZEstatic ConfigOption<MemorySize>TaskManagerOptions. TASK_OFF_HEAP_MEMORYTask Off-Heap Memory size for TaskExecutors.static ConfigOption<MemorySize>JobManagerOptions. TOTAL_FLINK_MEMORYTotal Flink Memory size for the JobManager.static ConfigOption<MemorySize>TaskManagerOptions. TOTAL_FLINK_MEMORYTotal Flink Memory size for the TaskExecutors.static ConfigOption<MemorySize>JobManagerOptions. TOTAL_PROCESS_MEMORYTotal Process Memory size for the JobManager.static ConfigOption<MemorySize>TaskManagerOptions. TOTAL_PROCESS_MEMORYTotal Process Memory size for the TaskExecutors.Methods in org.apache.flink.configuration that return MemorySize Modifier and Type Method Description MemorySizeMemorySize. add(MemorySize that)MemorySizeMemorySize. divide(long by)MemorySizeMemorySize. multiply(double multiplier)static MemorySizeMemorySize. ofMebiBytes(long mebiBytes)static MemorySizeMemorySize. parse(String text)Parses the given string as as MemorySize.static MemorySizeMemorySize. parse(String text, MemorySize.MemoryUnit defaultUnit)Parses the given string with a default unit.MemorySizeMemorySize. subtract(MemorySize that)Methods in org.apache.flink.configuration that return types with arguments of type MemorySize Modifier and Type Method Description ConfigOptions.TypedConfigOptionBuilder<MemorySize>ConfigOptions.OptionBuilder. memoryType()Defines that the value of the option should be ofMemorySizetype.Methods in org.apache.flink.configuration with parameters of type MemorySize Modifier and Type Method Description MemorySizeMemorySize. add(MemorySize that)intMemorySize. compareTo(MemorySize that)MemorySizeMemorySize. subtract(MemorySize that)
-