Package org.apache.flink.runtime.rest.messages.job

Class JobDetailsInfo.JobVertexDetailsInfo

java.lang.Object

org.apache.flink.runtime.rest.messages.job.JobDetailsInfo.JobVertexDetailsInfo

Enclosing class:

JobDetailsInfo

public static final class JobDetailsInfo.JobVertexDetailsInfo
extends java.lang.Object

Detailed information about a job vertex.

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	FIELD_NAME_JOB_VERTEX_DURATION
static java.lang.String	FIELD_NAME_JOB_VERTEX_END_TIME
static java.lang.String	FIELD_NAME_JOB_VERTEX_ID
static java.lang.String	FIELD_NAME_JOB_VERTEX_METRICS
static java.lang.String	FIELD_NAME_JOB_VERTEX_NAME
static java.lang.String	FIELD_NAME_JOB_VERTEX_START_TIME
static java.lang.String	FIELD_NAME_JOB_VERTEX_STATE
static java.lang.String	FIELD_NAME_MAX_PARALLELISM
static java.lang.String	FIELD_NAME_PARALLELISM
static java.lang.String	FIELD_NAME_SLOT_SHARING_GROUP_ID
static java.lang.String	FIELD_NAME_TASKS_PER_STATE

Constructor Summary

Constructors

Constructor

Description

JobVertexDetailsInfo(org.apache.flink.runtime.jobgraph.JobVertexID jobVertexID, org.apache.flink.runtime.instance.SlotSharingGroupId slotSharingGroupId, java.lang.String name, int maxParallelism, int parallelism, org.apache.flink.runtime.execution.ExecutionState executionState, long startTime, long endTime, long duration, java.util.Map<org.apache.flink.runtime.execution.ExecutionState,java.lang.Integer> tasksPerState, IOMetricsInfo jobVertexMetrics)

Method Summary

Modifier and Type	Method	Description
boolean	equals(java.lang.Object o)
long	getDuration()
long	getEndTime()
org.apache.flink.runtime.execution.ExecutionState	getExecutionState()
org.apache.flink.runtime.jobgraph.JobVertexID	getJobVertexID()
IOMetricsInfo	getJobVertexMetrics()
int	getMaxParallelism()
java.lang.String	getName()
int	getParallelism()
org.apache.flink.runtime.instance.SlotSharingGroupId	getSlotSharingGroupId()
long	getStartTime()
java.util.Map<org.apache.flink.runtime.execution.ExecutionState,java.lang.Integer>	getTasksPerState()
int	hashCode()

Methods inherited from class java.lang.Object

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

Field Detail

FIELD_NAME_JOB_VERTEX_ID

public static final java.lang.String FIELD_NAME_JOB_VERTEX_ID

See Also:

Constant Field Values

FIELD_NAME_SLOT_SHARING_GROUP_ID

public static final java.lang.String FIELD_NAME_SLOT_SHARING_GROUP_ID

See Also:

Constant Field Values

FIELD_NAME_JOB_VERTEX_NAME

public static final java.lang.String FIELD_NAME_JOB_VERTEX_NAME

See Also:

Constant Field Values

FIELD_NAME_MAX_PARALLELISM

public static final java.lang.String FIELD_NAME_MAX_PARALLELISM

See Also:

Constant Field Values

FIELD_NAME_PARALLELISM

public static final java.lang.String FIELD_NAME_PARALLELISM

See Also:

Constant Field Values

FIELD_NAME_JOB_VERTEX_STATE

public static final java.lang.String FIELD_NAME_JOB_VERTEX_STATE

See Also:

Constant Field Values

FIELD_NAME_JOB_VERTEX_START_TIME

public static final java.lang.String FIELD_NAME_JOB_VERTEX_START_TIME

See Also:

Constant Field Values

FIELD_NAME_JOB_VERTEX_END_TIME

public static final java.lang.String FIELD_NAME_JOB_VERTEX_END_TIME

See Also:

Constant Field Values

FIELD_NAME_JOB_VERTEX_DURATION

public static final java.lang.String FIELD_NAME_JOB_VERTEX_DURATION

See Also:

Constant Field Values

FIELD_NAME_TASKS_PER_STATE

public static final java.lang.String FIELD_NAME_TASKS_PER_STATE

See Also:

Constant Field Values

FIELD_NAME_JOB_VERTEX_METRICS

public static final java.lang.String FIELD_NAME_JOB_VERTEX_METRICS

See Also:

Constant Field Values

Constructor Detail

JobVertexDetailsInfo

public JobVertexDetailsInfo(org.apache.flink.runtime.jobgraph.JobVertexID jobVertexID,
                            org.apache.flink.runtime.instance.SlotSharingGroupId slotSharingGroupId,
                            java.lang.String name,
                            int maxParallelism,
                            int parallelism,
                            org.apache.flink.runtime.execution.ExecutionState executionState,
                            long startTime,
                            long endTime,
                            long duration,
                            java.util.Map<org.apache.flink.runtime.execution.ExecutionState,java.lang.Integer> tasksPerState,
                            IOMetricsInfo jobVertexMetrics)

Method Detail

getJobVertexID

public org.apache.flink.runtime.jobgraph.JobVertexID getJobVertexID()

getSlotSharingGroupId

public org.apache.flink.runtime.instance.SlotSharingGroupId getSlotSharingGroupId()

getName

public java.lang.String getName()

getMaxParallelism

public int getMaxParallelism()

getParallelism

public int getParallelism()

getExecutionState

public org.apache.flink.runtime.execution.ExecutionState getExecutionState()

getStartTime

public long getStartTime()

getEndTime

public long getEndTime()

getDuration

public long getDuration()

getTasksPerState

public java.util.Map<org.apache.flink.runtime.execution.ExecutionState,java.lang.Integer> getTasksPerState()

getJobVertexMetrics

public IOMetricsInfo getJobVertexMetrics()

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object