Package org.apache.flink.runtime.scheduler.adaptive.allocator

Interface ReserveSlotFunction

  • Functional Interface:
    This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
    @FunctionalInterface
public interface ReserveSlotFunction
    A function for reserving slots.

    • Method Detail

      • reserveSlot

        PhysicalSlot reserveSlot​(AllocationID allocationId,
                         ResourceProfile resourceProfile)
        Reserves the slot identified by the given allocation ID for the given resource profile.
        Parameters:
        allocationId - identifies the slot
        resourceProfile - resource profile the slot must be able to fulfill
        Returns:
        reserved slot