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

Class JobDetailsInfo

java.lang.Object

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

All Implemented Interfaces:

org.apache.flink.runtime.rest.messages.ResponseBody

public class JobDetailsInfo
extends java.lang.Object
implements org.apache.flink.runtime.rest.messages.ResponseBody

The difference compared to 1.18 is that slot sharing group is optional here.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	JobDetailsInfo.JobVertexDetailsInfo	Detailed information about a job vertex.

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	FIELD_NAME_DURATION
static java.lang.String	FIELD_NAME_END_TIME
static java.lang.String	FIELD_NAME_IS_STOPPABLE
static java.lang.String	FIELD_NAME_JOB_ID
static java.lang.String	FIELD_NAME_JOB_NAME
static java.lang.String	FIELD_NAME_JOB_STATUS
static java.lang.String	FIELD_NAME_JOB_VERTEX_INFOS
static java.lang.String	FIELD_NAME_JOB_VERTICES_PER_STATE
static java.lang.String	FIELD_NAME_JSON_PLAN
static java.lang.String	FIELD_NAME_MAX_PARALLELISM
static java.lang.String	FIELD_NAME_NOW
static java.lang.String	FIELD_NAME_START_TIME
static java.lang.String	FIELD_NAME_TIMESTAMPS

Constructor Summary

Constructors

Constructor

Description

JobDetailsInfo(org.apache.flink.api.common.JobID jobId, java.lang.String name, boolean isStoppable, org.apache.flink.api.common.JobStatus jobStatus, long startTime, long endTime, long duration, long maxParallelism, long now, java.util.Map<org.apache.flink.api.common.JobStatus,java.lang.Long> timestamps, java.util.Collection<JobDetailsInfo.JobVertexDetailsInfo> jobVertexInfos, java.util.Map<org.apache.flink.runtime.execution.ExecutionState,java.lang.Integer> jobVerticesPerState, org.apache.flink.runtime.rest.messages.JobPlanInfo.RawJson jsonPlan)

Method Summary

Modifier and Type	Method	Description
boolean	equals(java.lang.Object o)
long	getDuration()
long	getEndTime()
org.apache.flink.api.common.JobID	getJobId()
org.apache.flink.api.common.JobStatus	getJobStatus()
java.util.Collection<JobDetailsInfo.JobVertexDetailsInfo>	getJobVertexInfos()
java.util.Map<org.apache.flink.runtime.execution.ExecutionState,java.lang.Integer>	getJobVerticesPerState()
java.lang.String	getJsonPlan()
long	getMaxParallelism()
java.lang.String	getName()
long	getNow()
long	getStartTime()
java.util.Map<org.apache.flink.api.common.JobStatus,java.lang.Long>	getTimestamps()
int	hashCode()
boolean	isStoppable()

Methods inherited from class java.lang.Object

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

Field Detail

FIELD_NAME_JOB_ID

public static final java.lang.String FIELD_NAME_JOB_ID

See Also:

Constant Field Values

FIELD_NAME_JOB_NAME

public static final java.lang.String FIELD_NAME_JOB_NAME

See Also:

Constant Field Values

FIELD_NAME_IS_STOPPABLE

public static final java.lang.String FIELD_NAME_IS_STOPPABLE

See Also:

Constant Field Values

FIELD_NAME_JOB_STATUS

public static final java.lang.String FIELD_NAME_JOB_STATUS

See Also:

Constant Field Values

FIELD_NAME_START_TIME

public static final java.lang.String FIELD_NAME_START_TIME

See Also:

Constant Field Values

FIELD_NAME_END_TIME

public static final java.lang.String FIELD_NAME_END_TIME

See Also:

Constant Field Values

FIELD_NAME_DURATION

public static final java.lang.String FIELD_NAME_DURATION

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_NOW

public static final java.lang.String FIELD_NAME_NOW

See Also:

Constant Field Values

FIELD_NAME_TIMESTAMPS

public static final java.lang.String FIELD_NAME_TIMESTAMPS

See Also:

Constant Field Values

FIELD_NAME_JOB_VERTEX_INFOS

public static final java.lang.String FIELD_NAME_JOB_VERTEX_INFOS

See Also:

Constant Field Values

FIELD_NAME_JOB_VERTICES_PER_STATE

public static final java.lang.String FIELD_NAME_JOB_VERTICES_PER_STATE

See Also:

Constant Field Values

FIELD_NAME_JSON_PLAN

public static final java.lang.String FIELD_NAME_JSON_PLAN

See Also:

Constant Field Values

Constructor Detail

JobDetailsInfo

public JobDetailsInfo(org.apache.flink.api.common.JobID jobId,
                      java.lang.String name,
                      boolean isStoppable,
                      org.apache.flink.api.common.JobStatus jobStatus,
                      long startTime,
                      long endTime,
                      long duration,
                      long maxParallelism,
                      long now,
                      java.util.Map<org.apache.flink.api.common.JobStatus,java.lang.Long> timestamps,
                      java.util.Collection<JobDetailsInfo.JobVertexDetailsInfo> jobVertexInfos,
                      java.util.Map<org.apache.flink.runtime.execution.ExecutionState,java.lang.Integer> jobVerticesPerState,
                      org.apache.flink.runtime.rest.messages.JobPlanInfo.RawJson jsonPlan)

Method Detail

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

getJobId

public org.apache.flink.api.common.JobID getJobId()

getName

public java.lang.String getName()

isStoppable

public boolean isStoppable()

getJobStatus

public org.apache.flink.api.common.JobStatus getJobStatus()

getStartTime

public long getStartTime()

getEndTime

public long getEndTime()

getMaxParallelism

public long getMaxParallelism()

getDuration

public long getDuration()

getNow

public long getNow()

getTimestamps

public java.util.Map<org.apache.flink.api.common.JobStatus,java.lang.Long> getTimestamps()

getJobVertexInfos

public java.util.Collection<JobDetailsInfo.JobVertexDetailsInfo> getJobVertexInfos()

getJobVerticesPerState

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

getJsonPlan

public java.lang.String getJsonPlan()