org.apache.flink.runtime.rest.messages.taskmanager

Class TaskManagerInfo

java.lang.Object

org.apache.flink.runtime.rest.messages.taskmanager.TaskManagerInfo

All Implemented Interfaces:

Serializable, ResponseBody

Direct Known Subclasses:

TaskManagerDetailsInfo

public class TaskManagerInfo
extends Object
implements ResponseBody, Serializable

Base class containing information for a TaskExecutor.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static String	FIELD_NAME_ADDRESS
static String	FIELD_NAME_AVAILABLE_RESOURCE
static String	FIELD_NAME_BLOCKED
static String	FIELD_NAME_DATA_PORT
static String	FIELD_NAME_HARDWARE
static String	FIELD_NAME_JMX_PORT
static String	FIELD_NAME_LAST_HEARTBEAT
static String	FIELD_NAME_MEMORY
static String	FIELD_NAME_NUMBER_AVAILABLE_SLOTS
static String	FIELD_NAME_NUMBER_SLOTS
static String	FIELD_NAME_RESOURCE_ID
static String	FIELD_NAME_TOTAL_RESOURCE

Constructor Summary

Constructors

Constructor and Description
TaskManagerInfo(ResourceID resourceId, String address, int dataPort, int jmxPort, long lastHeartbeat, int numberSlots, int numberAvailableSlots, ResourceProfileInfo totalResource, ResourceProfileInfo freeResource, HardwareDescription hardwareDescription, TaskExecutorMemoryConfiguration memoryConfiguration, Boolean blocked)
TaskManagerInfo(ResourceID resourceId, String address, int dataPort, int jmxPort, long lastHeartbeat, int numberSlots, int numberAvailableSlots, ResourceProfile totalResource, ResourceProfile freeResource, HardwareDescription hardwareDescription, TaskExecutorMemoryConfiguration memoryConfiguration, Boolean blocked)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
String	getAddress()
boolean	getBlocked()
int	getDataPort()
ResourceProfileInfo	getFreeResource()
HardwareDescription	getHardwareDescription()
int	getJmxPort()
long	getLastHeartbeat()
TaskExecutorMemoryConfiguration	getMemoryConfiguration()
int	getNumberAvailableSlots()
int	getNumberSlots()
ResourceID	getResourceId()
ResourceProfileInfo	getTotalResource()
int	hashCode()

Methods inherited from class java.lang.Object

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

Field Detail

FIELD_NAME_RESOURCE_ID

public static final String FIELD_NAME_RESOURCE_ID

See Also:

Constant Field Values

FIELD_NAME_ADDRESS

public static final String FIELD_NAME_ADDRESS

See Also:

Constant Field Values

FIELD_NAME_DATA_PORT

public static final String FIELD_NAME_DATA_PORT

See Also:

Constant Field Values

FIELD_NAME_JMX_PORT

public static final String FIELD_NAME_JMX_PORT

See Also:

Constant Field Values

FIELD_NAME_LAST_HEARTBEAT

public static final String FIELD_NAME_LAST_HEARTBEAT

See Also:

Constant Field Values

FIELD_NAME_NUMBER_SLOTS

public static final String FIELD_NAME_NUMBER_SLOTS

See Also:

Constant Field Values

FIELD_NAME_NUMBER_AVAILABLE_SLOTS

public static final String FIELD_NAME_NUMBER_AVAILABLE_SLOTS

See Also:

Constant Field Values

FIELD_NAME_TOTAL_RESOURCE

public static final String FIELD_NAME_TOTAL_RESOURCE

See Also:

Constant Field Values

FIELD_NAME_AVAILABLE_RESOURCE

public static final String FIELD_NAME_AVAILABLE_RESOURCE

See Also:

Constant Field Values

FIELD_NAME_HARDWARE

public static final String FIELD_NAME_HARDWARE

See Also:

Constant Field Values

FIELD_NAME_MEMORY

public static final String FIELD_NAME_MEMORY

See Also:

Constant Field Values

FIELD_NAME_BLOCKED

public static final String FIELD_NAME_BLOCKED

See Also:

Constant Field Values

Constructor Detail

TaskManagerInfo

public TaskManagerInfo(ResourceID resourceId,
                       String address,
                       int dataPort,
                       int jmxPort,
                       long lastHeartbeat,
                       int numberSlots,
                       int numberAvailableSlots,
                       ResourceProfileInfo totalResource,
                       ResourceProfileInfo freeResource,
                       HardwareDescription hardwareDescription,
                       TaskExecutorMemoryConfiguration memoryConfiguration,
                       @Nullable
                       Boolean blocked)

TaskManagerInfo

public TaskManagerInfo(ResourceID resourceId,
                       String address,
                       int dataPort,
                       int jmxPort,
                       long lastHeartbeat,
                       int numberSlots,
                       int numberAvailableSlots,
                       ResourceProfile totalResource,
                       ResourceProfile freeResource,
                       HardwareDescription hardwareDescription,
                       TaskExecutorMemoryConfiguration memoryConfiguration,
                       @Nullable
                       Boolean blocked)

Method Detail

getResourceId

public ResourceID getResourceId()

getAddress

public String getAddress()

getDataPort

public int getDataPort()

getJmxPort

public int getJmxPort()

getLastHeartbeat

public long getLastHeartbeat()

getNumberSlots

public int getNumberSlots()

getNumberAvailableSlots

public int getNumberAvailableSlots()

getTotalResource

public ResourceProfileInfo getTotalResource()

getFreeResource

public ResourceProfileInfo getFreeResource()

getHardwareDescription

public HardwareDescription getHardwareDescription()

getMemoryConfiguration

public TaskExecutorMemoryConfiguration getMemoryConfiguration()

getBlocked

public boolean getBlocked()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object