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

Class SubtaskExecutionAttemptDetailsInfo

java.lang.Object

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

All Implemented Interfaces:

ResponseBody

public class SubtaskExecutionAttemptDetailsInfo
extends Object
implements ResponseBody

The sub task execution attempt response.

Field Summary

Fields

Modifier and Type	Field and Description
static String	FIELD_NAME_ATTEMPT
static String	FIELD_NAME_COMPATIBLE_START_TIME
static String	FIELD_NAME_DURATION
static String	FIELD_NAME_END_TIME
static String	FIELD_NAME_ENDPOINT
static String	FIELD_NAME_HOST Deprecated.
static String	FIELD_NAME_METRICS
static String	FIELD_NAME_OTHER_CONCURRENT_ATTEMPTS
static String	FIELD_NAME_START_TIME
static String	FIELD_NAME_STATUS
static String	FIELD_NAME_STATUS_DURATION
static String	FIELD_NAME_SUBTASK_INDEX
static String	FIELD_NAME_TASKMANAGER_ID

Constructor Summary

Constructors

Constructor and Description
SubtaskExecutionAttemptDetailsInfo(int subtaskIndex, ExecutionState status, int attempt, String host, String endpoint, long startTime, long endTime, long duration, IOMetricsInfo ioMetricsInfo, String taskmanagerId, Map<ExecutionState,Long> statusDuration, List<SubtaskExecutionAttemptDetailsInfo> otherConcurrentAttempts)

Method Summary

Modifier and Type	Method and Description
static SubtaskExecutionAttemptDetailsInfo	create(AccessExecution execution, MetricFetcher metricFetcher, JobID jobID, JobVertexID jobVertexID, List<SubtaskExecutionAttemptDetailsInfo> otherConcurrentAttempts)
boolean	equals(Object o)
int	getAttempt()
long	getDuration()
String	getEndpoint()
long	getEndTime()
String	getHost() Deprecated.
IOMetricsInfo	getIoMetricsInfo()
List<SubtaskExecutionAttemptDetailsInfo>	getOtherConcurrentAttempts()
long	getStartTime()
long	getStartTimeCompatible()
ExecutionState	getStatus()
Map<ExecutionState,Long>	getStatusDuration()
long	getStatusDuration(ExecutionState state)
int	getSubtaskIndex()
String	getTaskmanagerId()
int	hashCode()

Methods inherited from class java.lang.Object

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

Field Detail

FIELD_NAME_SUBTASK_INDEX

public static final String FIELD_NAME_SUBTASK_INDEX

See Also:

Constant Field Values

FIELD_NAME_STATUS

public static final String FIELD_NAME_STATUS

See Also:

Constant Field Values

FIELD_NAME_ATTEMPT

public static final String FIELD_NAME_ATTEMPT

See Also:

Constant Field Values

FIELD_NAME_HOST

@Deprecated
public static final String FIELD_NAME_HOST

Deprecated.

See Also:

Constant Field Values

FIELD_NAME_ENDPOINT

public static final String FIELD_NAME_ENDPOINT

See Also:

Constant Field Values

FIELD_NAME_START_TIME

public static final String FIELD_NAME_START_TIME

See Also:

Constant Field Values

FIELD_NAME_COMPATIBLE_START_TIME

public static final String FIELD_NAME_COMPATIBLE_START_TIME

See Also:

Constant Field Values

FIELD_NAME_END_TIME

public static final String FIELD_NAME_END_TIME

See Also:

Constant Field Values

FIELD_NAME_DURATION

public static final String FIELD_NAME_DURATION

See Also:

Constant Field Values

FIELD_NAME_METRICS

public static final String FIELD_NAME_METRICS

See Also:

Constant Field Values

FIELD_NAME_TASKMANAGER_ID

public static final String FIELD_NAME_TASKMANAGER_ID

See Also:

Constant Field Values

FIELD_NAME_STATUS_DURATION

public static final String FIELD_NAME_STATUS_DURATION

See Also:

Constant Field Values

FIELD_NAME_OTHER_CONCURRENT_ATTEMPTS

public static final String FIELD_NAME_OTHER_CONCURRENT_ATTEMPTS

See Also:

Constant Field Values

Constructor Detail

SubtaskExecutionAttemptDetailsInfo

public SubtaskExecutionAttemptDetailsInfo(int subtaskIndex,
                                          ExecutionState status,
                                          int attempt,
                                          String host,
                                          String endpoint,
                                          long startTime,
                                          long endTime,
                                          long duration,
                                          IOMetricsInfo ioMetricsInfo,
                                          String taskmanagerId,
                                          Map<ExecutionState,Long> statusDuration,
                                          @Nullable
                                          List<SubtaskExecutionAttemptDetailsInfo> otherConcurrentAttempts)

Method Detail

getSubtaskIndex

public int getSubtaskIndex()

getStatus

public ExecutionState getStatus()

getAttempt

public int getAttempt()

getHost

@Deprecated
public String getHost()

Deprecated.

getEndpoint

public String getEndpoint()

getStartTime

public long getStartTime()

getStartTimeCompatible

public long getStartTimeCompatible()

getEndTime

public long getEndTime()

getDuration

public long getDuration()

getStatusDuration

public Map<ExecutionState,Long> getStatusDuration()

getStatusDuration

public long getStatusDuration(ExecutionState state)

getIoMetricsInfo

public IOMetricsInfo getIoMetricsInfo()

getTaskmanagerId

public String getTaskmanagerId()

getOtherConcurrentAttempts

public List<SubtaskExecutionAttemptDetailsInfo> getOtherConcurrentAttempts()

create

public static SubtaskExecutionAttemptDetailsInfo create(AccessExecution execution,
                                                        @Nullable
                                                        MetricFetcher metricFetcher,
                                                        JobID jobID,
                                                        JobVertexID jobVertexID,
                                                        @Nullable
                                                        List<SubtaskExecutionAttemptDetailsInfo> otherConcurrentAttempts)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object