Interface DeclarativeSlotPool.NewSlotsListener
-
- All Known Implementing Classes:
DeclarativeSlotPool.NoOpNewSlotsListener
- Enclosing interface:
- DeclarativeSlotPool
public static interface DeclarativeSlotPool.NewSlotsListener
Listener interface for newly available slots.Implementations of the
DeclarativeSlotPool
will callnotifyNewSlotsAreAvailable(java.util.Collection<? extends org.apache.flink.runtime.jobmaster.slotpool.PhysicalSlot>)
whenever newly offered slots are accepted or if an allocated slot should become free after it is beingfreed
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
notifyNewSlotsAreAvailable(Collection<? extends PhysicalSlot> newlyAvailableSlots)
Notifies the listener about newly available slots.
-
-
-
Method Detail
-
notifyNewSlotsAreAvailable
void notifyNewSlotsAreAvailable(Collection<? extends PhysicalSlot> newlyAvailableSlots)
Notifies the listener about newly available slots.This method will be called whenever newly offered slots are accepted or if an allocated slot should become free after it is being
freed
.- Parameters:
newlyAvailableSlots
- are the newly available slots
-
-