org.apache.flink.runtime.instance

Interface SlotPoolGateway

All Superinterfaces:

RpcGateway

All Known Implementing Classes:

SlotPool

public interface SlotPoolGateway
extends RpcGateway

The gateway for calls on the SlotPool.

Method Summary

Modifier and Type	Method and Description
CompletableFuture<SimpleSlot>	allocateSlot(ScheduledUnit task, ResourceProfile resources, Iterable<TaskManagerLocation> locationPreferences, Time timeout)
void	connectToResourceManager(ResourceManagerGateway resourceManagerGateway) Connects the SlotPool to the given ResourceManager.
void	disconnectResourceManager() Disconnects the slot pool from its current Resource Manager.
void	failAllocation(AllocationID allocationID, Exception cause)
CompletableFuture<Boolean>	offerSlot(AllocatedSlot slot)
CompletableFuture<Collection<SlotOffer>>	offerSlots(Collection<Tuple2<AllocatedSlot,SlotOffer>> offers)
void	registerTaskManager(ResourceID resourceID)
CompletableFuture<Acknowledge>	releaseTaskManager(ResourceID resourceID)
void	returnAllocatedSlot(Slot slot)
void	suspend()

Methods inherited from interface org.apache.flink.runtime.rpc.RpcGateway

getAddress, getHostname

Method Detail

suspend

void suspend()

connectToResourceManager

void connectToResourceManager(ResourceManagerGateway resourceManagerGateway)

Connects the SlotPool to the given ResourceManager. After this method is called, the SlotPool will be able to request resources from the given ResourceManager.

Parameters:

resourceManagerGateway - The RPC gateway for the resource manager.

disconnectResourceManager

void disconnectResourceManager()

Disconnects the slot pool from its current Resource Manager. After this call, the pool will not be able to request further slots from the Resource Manager, and all currently pending requests to the resource manager will be canceled.

The slot pool will still be able to serve slots from its internal pool.

registerTaskManager

void registerTaskManager(ResourceID resourceID)

releaseTaskManager

CompletableFuture<Acknowledge> releaseTaskManager(ResourceID resourceID)

offerSlot

CompletableFuture<Boolean> offerSlot(AllocatedSlot slot)

offerSlots

CompletableFuture<Collection<SlotOffer>> offerSlots(Collection<Tuple2<AllocatedSlot,SlotOffer>> offers)

failAllocation

void failAllocation(AllocationID allocationID,
                    Exception cause)

allocateSlot

CompletableFuture<SimpleSlot> allocateSlot(ScheduledUnit task,
                                           ResourceProfile resources,
                                           Iterable<TaskManagerLocation> locationPreferences,
                                           Time timeout)

returnAllocatedSlot

void returnAllocatedSlot(Slot slot)