public static final class JobDetailsInfo.JobVertexDetailsInfo extends Object
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_MAX_PARALLELISM |
static String |
FIELD_NAME_PARALLELISM |
static String |
FIELD_NAME_SLOT_SHARING_GROUP_ID |
static String |
FIELD_NAME_TASKS_PER_STATE |
Constructor and Description |
---|
JobVertexDetailsInfo(JobVertexID jobVertexID,
SlotSharingGroupId slotSharingGroupId,
String name,
int maxParallelism,
int parallelism,
ExecutionState executionState,
long startTime,
long endTime,
long duration,
Map<ExecutionState,Integer> tasksPerState,
IOMetricsInfo jobVertexMetrics) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
long |
getDuration() |
long |
getEndTime() |
ExecutionState |
getExecutionState() |
JobVertexID |
getJobVertexID() |
IOMetricsInfo |
getJobVertexMetrics() |
int |
getMaxParallelism() |
String |
getName() |
int |
getParallelism() |
SlotSharingGroupId |
getSlotSharingGroupId() |
long |
getStartTime() |
Map<ExecutionState,Integer> |
getTasksPerState() |
int |
hashCode() |
public static final String FIELD_NAME_JOB_VERTEX_ID
public static final String FIELD_NAME_SLOT_SHARING_GROUP_ID
public static final String FIELD_NAME_JOB_VERTEX_NAME
public static final String FIELD_NAME_MAX_PARALLELISM
public static final String FIELD_NAME_PARALLELISM
public static final String FIELD_NAME_JOB_VERTEX_STATE
public static final String FIELD_NAME_JOB_VERTEX_START_TIME
public static final String FIELD_NAME_JOB_VERTEX_END_TIME
public static final String FIELD_NAME_JOB_VERTEX_DURATION
public static final String FIELD_NAME_TASKS_PER_STATE
public static final String FIELD_NAME_JOB_VERTEX_METRICS
public JobVertexDetailsInfo(JobVertexID jobVertexID, SlotSharingGroupId slotSharingGroupId, String name, int maxParallelism, int parallelism, ExecutionState executionState, long startTime, long endTime, long duration, Map<ExecutionState,Integer> tasksPerState, IOMetricsInfo jobVertexMetrics)
public JobVertexID getJobVertexID()
public SlotSharingGroupId getSlotSharingGroupId()
public String getName()
public int getMaxParallelism()
public int getParallelism()
public ExecutionState getExecutionState()
public long getStartTime()
public long getEndTime()
public long getDuration()
public Map<ExecutionState,Integer> getTasksPerState()
public IOMetricsInfo getJobVertexMetrics()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.