Package | Description |
---|---|
org.apache.flink.runtime.resourcemanager.slotmanager |
Modifier and Type | Class and Description |
---|---|
class |
DefaultResourceTracker
Default
ResourceTracker implementation. |
Modifier and Type | Method and Description |
---|---|
void |
SlotStatusSyncer.initialize(org.apache.flink.runtime.resourcemanager.slotmanager.TaskManagerTracker taskManagerTracker,
ResourceTracker resourceTracker,
ResourceManagerId resourceManagerId,
Executor mainThreadExecutor)
Initialize this syncer.
|
void |
DefaultSlotStatusSyncer.initialize(org.apache.flink.runtime.resourcemanager.slotmanager.TaskManagerTracker taskManagerTracker,
ResourceTracker resourceTracker,
ResourceManagerId resourceManagerId,
Executor mainThreadExecutor) |
Constructor and Description |
---|
DeclarativeSlotManager(ScheduledExecutor scheduledExecutor,
SlotManagerConfiguration slotManagerConfiguration,
SlotManagerMetricGroup slotManagerMetricGroup,
ResourceTracker resourceTracker,
org.apache.flink.runtime.resourcemanager.slotmanager.SlotTracker slotTracker) |
FineGrainedSlotManager(ScheduledExecutor scheduledExecutor,
SlotManagerConfiguration slotManagerConfiguration,
SlotManagerMetricGroup slotManagerMetricGroup,
ResourceTracker resourceTracker,
org.apache.flink.runtime.resourcemanager.slotmanager.TaskManagerTracker taskManagerTracker,
SlotStatusSyncer slotStatusSyncer,
ResourceAllocationStrategy resourceAllocationStrategy) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.