org.apache.flink.runtime.instance

Class Slot

java.lang.Object

org.apache.flink.runtime.instance.Slot

Direct Known Subclasses:

SharedSlot, SimpleSlot

public abstract class Slot
extends Object

Base class for task slots. TaskManagers offer one or more task slots, they define how many parallel tasks or task groups a TaskManager executes.

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	ALLOCATED_AND_ALIVE
protected static int	CANCELLED
protected static int	RELEASED

Constructor Summary

Constructors

Constructor and Description
Slot(JobID jobID, Instance instance, int slotNumber, SharedSlot parent, AbstractID groupID)

Method Summary

Modifier and Type	Method and Description
abstract void	cancel()
AbstractID	getGroupID()
Instance	getInstance()
JobID	getJobID() Returns the ID of the job this allocated slot belongs to.
abstract int	getNumberLeaves()
SharedSlot	getParent()
Slot	getRoot()
int	getSlotNumber()
int	getStatus()
protected String	hierarchy()
boolean	isAlive()
boolean	isCanceled()
boolean	isDead()
boolean	isDisposed()
boolean	isReleased()
boolean	markCancelled()
boolean	markDead() Marks this shared slot to be dead.
boolean	markDisposed()
boolean	markReleased()
abstract void	releaseSlot()
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

ALLOCATED_AND_ALIVE

protected static final int ALLOCATED_AND_ALIVE

See Also:

Constant Field Values

CANCELLED

protected static final int CANCELLED

See Also:

Constant Field Values

RELEASED

protected static final int RELEASED

See Also:

Constant Field Values

Constructor Detail

Slot

public Slot(JobID jobID,
            Instance instance,
            int slotNumber,
            SharedSlot parent,
            AbstractID groupID)

Method Detail

getJobID

public JobID getJobID()

Returns the ID of the job this allocated slot belongs to.

Returns:

the ID of the job this allocated slot belongs to

getInstance

public Instance getInstance()

getSlotNumber

public int getSlotNumber()

getGroupID

public AbstractID getGroupID()

getParent

public SharedSlot getParent()

getRoot

public Slot getRoot()

getStatus

public int getStatus()

getNumberLeaves

public abstract int getNumberLeaves()

isAlive

public boolean isAlive()

isCanceled

public boolean isCanceled()

isReleased

public boolean isReleased()

cancel

public abstract void cancel()

releaseSlot

public abstract void releaseSlot()

markReleased

public boolean markReleased()

markCancelled

public boolean markCancelled()

markDead

public boolean markDead()

Marks this shared slot to be dead. Returns if the slot was alive before. Should only be called through the SlotSharingGroupAssignment attribute assignmentGroup.

Returns:

if the slot was alive before

isDead

public boolean isDead()

markDisposed

public boolean markDisposed()

isDisposed

public boolean isDisposed()

toString

public String toString()

Overrides:

toString in class Object

hierarchy

protected String hierarchy()