org.apache.flink.runtime.clusterframework.types

Class AllocationID

java.lang.Object

org.apache.flink.util.AbstractID

org.apache.flink.runtime.clusterframework.types.AllocationID

All Implemented Interfaces:

Serializable, Comparable<AbstractID>

public class AllocationID
extends AbstractID

Unique identifier for a physical slot allocated by a JobManager via the ResourceManager from a TaskManager. The ID is assigned once the JobManager (or its SlotPool) first requests the slot and is constant across retries.

This ID is used by the TaskManager and ResourceManager to track and synchronize which slots are allocated to which JobManager and which are free.

In contrast to this AllocationID, the SlotRequestId is used when a task requests a logical slot from the SlotPool. Multiple logical slot requests can map to one physical slot request (due to slot sharing).

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.flink.util.AbstractID

lowerPart, SIZE, upperPart

Constructor Summary

Constructors

Constructor and Description
AllocationID() Constructs a new random AllocationID.
AllocationID(long lowerPart, long upperPart) Constructs a new AllocationID with the given parts.

Method Summary

Modifier and Type	Method and Description
static AllocationID	fromHexString(String hexString)

Methods inherited from class org.apache.flink.util.AbstractID

compareTo, equals, getBytes, getLowerPart, getUpperPart, hashCode, toHexString, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

AllocationID

public AllocationID()

Constructs a new random AllocationID.

AllocationID

public AllocationID(long lowerPart,
                    long upperPart)

Constructs a new AllocationID with the given parts.

Parameters:

lowerPart - the lower bytes of the ID

upperPart - the higher bytes of the ID

Method Detail

fromHexString

public static AllocationID fromHexString(String hexString)