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 Object

Detailed information about a job vertex.

Field Summary

Fields

Modifier and Type	Field and Description
static String	FIELD_NAME_JOB_VERTEX_DURATION
static String	FIELD_NAME_JOB_VERTEX_END_TIME
static String	FIELD_NAME_JOB_VERTEX_ID
static String	FIELD_NAME_JOB_VERTEX_METRICS
static String	FIELD_NAME_JOB_VERTEX_NAME
static String	FIELD_NAME_JOB_VERTEX_START_TIME
static String	FIELD_NAME_JOB_VERTEX_STATE
static String	FIELD_NAME_PARALLELISM
static String	FIELD_NAME_TASKS_PER_STATE

Constructor Summary

Constructors

Constructor and Description
JobVertexDetailsInfo(JobVertexID jobVertexID, String name, int parallelism, ExecutionState executionState, long startTime, long endTime, long duration, Map<ExecutionState,Integer> tasksPerState, IOMetricsInfo jobVertexMetrics)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
long	getDuration()
long	getEndTime()
ExecutionState	getExecutionState()
JobVertexID	getJobVertexID()
IOMetricsInfo	getJobVertexMetrics()
String	getName()
int	getParallelism()
long	getStartTime()
Map<ExecutionState,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 String FIELD_NAME_JOB_VERTEX_ID

See Also:

Constant Field Values

FIELD_NAME_JOB_VERTEX_NAME

public static final String FIELD_NAME_JOB_VERTEX_NAME

See Also:

Constant Field Values

FIELD_NAME_PARALLELISM

public static final String FIELD_NAME_PARALLELISM

See Also:

Constant Field Values

FIELD_NAME_JOB_VERTEX_STATE

public static final String FIELD_NAME_JOB_VERTEX_STATE

See Also:

Constant Field Values

FIELD_NAME_JOB_VERTEX_START_TIME

public static final String FIELD_NAME_JOB_VERTEX_START_TIME

See Also:

Constant Field Values

FIELD_NAME_JOB_VERTEX_END_TIME

public static final String FIELD_NAME_JOB_VERTEX_END_TIME

See Also:

Constant Field Values

FIELD_NAME_JOB_VERTEX_DURATION

public static final String FIELD_NAME_JOB_VERTEX_DURATION

See Also:

Constant Field Values

FIELD_NAME_TASKS_PER_STATE

public static final String FIELD_NAME_TASKS_PER_STATE

See Also:

Constant Field Values

FIELD_NAME_JOB_VERTEX_METRICS

public static final String FIELD_NAME_JOB_VERTEX_METRICS

See Also:

Constant Field Values

Constructor Detail

JobVertexDetailsInfo

public JobVertexDetailsInfo(JobVertexID jobVertexID,
                            String name,
                            int parallelism,
                            ExecutionState executionState,
                            long startTime,
                            long endTime,
                            long duration,
                            Map<ExecutionState,Integer> tasksPerState,
                            IOMetricsInfo jobVertexMetrics)

Method Detail

getJobVertexID

public JobVertexID getJobVertexID()

getName

public String getName()

getParallelism

public int getParallelism()

getExecutionState

public ExecutionState getExecutionState()

getStartTime

public long getStartTime()

getEndTime

public long getEndTime()

getDuration

public long getDuration()

getTasksPerState

public Map<ExecutionState,Integer> getTasksPerState()

getJobVertexMetrics

public IOMetricsInfo getJobVertexMetrics()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object