org.apache.flink.runtime.resourcemanager.slotmanager

Class PendingSlotRequest

java.lang.Object

org.apache.flink.runtime.resourcemanager.slotmanager.PendingSlotRequest

public class PendingSlotRequest
extends Object

Constructor Summary

Constructors

Constructor and Description
PendingSlotRequest(SlotRequest slotRequest)

Method Summary

Modifier and Type	Method and Description
AllocationID	getAllocationId()
long	getCreationTimestamp()
JobID	getJobId()
CompletableFuture<Acknowledge>	getRequestFuture()
ResourceProfile	getResourceProfile()
String	getTargetAddress()
boolean	isAssigned()
void	setRequestFuture(CompletableFuture<Acknowledge> requestFuture)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PendingSlotRequest

public PendingSlotRequest(SlotRequest slotRequest)

Method Detail

getAllocationId

public AllocationID getAllocationId()

getResourceProfile

public ResourceProfile getResourceProfile()

getJobId

public JobID getJobId()

getTargetAddress

public String getTargetAddress()

getCreationTimestamp

public long getCreationTimestamp()

isAssigned

public boolean isAssigned()

setRequestFuture

public void setRequestFuture(@Nullable
                             CompletableFuture<Acknowledge> requestFuture)

getRequestFuture

@Nullable
public CompletableFuture<Acknowledge> getRequestFuture()