public interface FlinkMemory extends Serializable
The relationships of Flink JVM and rest memory components are shown below.
┌ ─ ─ Total Flink Memory - ─ ─ ┐ ┌───────────────────────────┐ | │ JVM Heap Memory │ | └───────────────────────────┘ |┌ ─ ─ - - - Off-Heap - - ─ ─ ┐| │┌───────────────────────────┐│ │ │ JVM Direct Memory │ │ │└───────────────────────────┘│ │ ┌───────────────────────────┐ │ ││ Rest Off-Heap Memory ││ │ └───────────────────────────┘ │ └ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ┘ └ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ┘
The JVM and rest memory components can consist of further concrete Flink memory components depending on the process type. The Flink memory components can be derived from either its total size or a subset of configured required fine-grained components. Check the implementations for details about the concrete components.
Modifier and Type | Method and Description |
---|---|
MemorySize |
getJvmDirectMemorySize() |
MemorySize |
getJvmHeapMemorySize() |
MemorySize |
getTotalFlinkMemorySize() |
MemorySize getJvmHeapMemorySize()
MemorySize getJvmDirectMemorySize()
MemorySize getTotalFlinkMemorySize()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.