Package | Description |
---|---|
org.apache.flink.runtime.taskexecutor.slot |
Modifier and Type | Method and Description |
---|---|
Collection<SlotAllocationSnapshot> |
SlotAllocationSnapshotPersistenceService.loadAllocationSnapshots()
Load all persisted slot allocation snapshots.
|
Collection<SlotAllocationSnapshot> |
FileSlotAllocationSnapshotPersistenceService.loadAllocationSnapshots() |
Collection<SlotAllocationSnapshot> |
NoOpSlotAllocationSnapshotPersistenceService.loadAllocationSnapshots() |
Modifier and Type | Method and Description |
---|---|
void |
SlotAllocationSnapshotPersistenceService.persistAllocationSnapshot(SlotAllocationSnapshot slotAllocationSnapshot)
Persist the given slot allocation snapshot.
|
void |
FileSlotAllocationSnapshotPersistenceService.persistAllocationSnapshot(SlotAllocationSnapshot slotAllocationSnapshot) |
void |
NoOpSlotAllocationSnapshotPersistenceService.persistAllocationSnapshot(SlotAllocationSnapshot slotAllocationSnapshot) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.