Package | Description |
---|---|
org.apache.flink.runtime.metrics.util | |
org.apache.flink.runtime.taskexecutor | |
org.apache.flink.runtime.taskexecutor.slot |
Modifier and Type | Method and Description |
---|---|
static void |
MetricUtils.instantiateFlinkMemoryMetricGroup(MetricGroup parentMetricGroup,
TaskSlotTable<?> taskSlotTable,
java.util.function.Supplier<Long> managedMemoryTotalSupplier) |
Modifier and Type | Method and Description |
---|---|
TaskSlotTable<Task> |
TaskManagerServices.getTaskSlotTable() |
Modifier and Type | Class and Description |
---|---|
class |
TaskSlotTableImpl<T extends TaskSlotPayload>
Default implementation of
TaskSlotTable . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.