org.apache.flink.runtime.jobmaster.slotpool

Interface PhysicalSlotRequestBulk

public interface PhysicalSlotRequestBulk

Represents a bulk of physical slot requests.

Method Summary

Modifier and Type	Method and Description
void	cancel(Throwable cause) Cancels all requests of this bulk.
Set<AllocationID>	getAllocationIdsOfFulfilledRequests() Returns AllocationIDs of fulfilled physical slot requests.
Collection<ResourceProfile>	getPendingRequests() Returns ResourceProfiles of pending physical slot requests.

Method Detail

getPendingRequests

Collection<ResourceProfile> getPendingRequests()

Returns ResourceProfiles of pending physical slot requests.

If a request is pending, it is not fulfilled and vice versa. getAllocationIdsOfFulfilledRequests() should not return a pending request.

getAllocationIdsOfFulfilledRequests

Set<AllocationID> getAllocationIdsOfFulfilledRequests()

Returns AllocationIDs of fulfilled physical slot requests.

If a request is fulfilled, it is not pending and vice versa. getPendingRequests() should not return a fulfilled request.

cancel

void cancel(Throwable cause)

Cancels all requests of this bulk.

Canceled bulk is not valid and should not be used afterwards.