org.apache.flink.runtime.jobmanager.scheduler

Class SlotAllocationFuture

java.lang.Object

org.apache.flink.runtime.jobmanager.scheduler.SlotAllocationFuture

public class SlotAllocationFuture
extends Object

Constructor Summary

Constructors

Constructor and Description
SlotAllocationFuture()
SlotAllocationFuture(SimpleSlot slot)

Method Summary

Modifier and Type	Method and Description
void	setFutureAction(SlotAllocationFutureAction action)
void	setSlot(SimpleSlot slot)
String	toString()
SimpleSlot	waitTillAllocated()
SimpleSlot	waitTillAllocated(long timeout)

Methods inherited from class java.lang.Object

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

Constructor Detail

SlotAllocationFuture

public SlotAllocationFuture()

SlotAllocationFuture

public SlotAllocationFuture(SimpleSlot slot)

Method Detail

waitTillAllocated

public SimpleSlot waitTillAllocated()
                             throws InterruptedException

Throws:

InterruptedException

waitTillAllocated

public SimpleSlot waitTillAllocated(long timeout)
                             throws InterruptedException

Throws:

InterruptedException

setFutureAction

public void setFutureAction(SlotAllocationFutureAction action)

setSlot

public void setSlot(SimpleSlot slot)

toString

public String toString()

Overrides:

toString in class Object