public class ExecutionJobVertex extends Object implements AccessExecutionJobVertex, Archiveable<ArchivedExecutionJobVertex>
Modifier and Type | Field and Description |
---|---|
static int |
VALUE_NOT_SET |
Constructor and Description |
---|
ExecutionJobVertex(ExecutionGraph graph,
JobVertex jobVertex,
int defaultParallelism,
Time timeout) |
ExecutionJobVertex(ExecutionGraph graph,
JobVertex jobVertex,
int defaultParallelism,
Time timeout,
long createTimestamp) |
public static final int VALUE_NOT_SET
public ExecutionJobVertex(ExecutionGraph graph, JobVertex jobVertex, int defaultParallelism, Time timeout) throws JobException
JobException
public ExecutionJobVertex(ExecutionGraph graph, JobVertex jobVertex, int defaultParallelism, Time timeout, long createTimestamp) throws JobException
JobException
public void setMaxParallelism(int maxParallelismDerived)
public ExecutionGraph getGraph()
public JobVertex getJobVertex()
public String getName()
AccessExecutionJobVertex
getName
in interface AccessExecutionJobVertex
public int getParallelism()
AccessExecutionJobVertex
getParallelism
in interface AccessExecutionJobVertex
public int getMaxParallelism()
AccessExecutionJobVertex
getMaxParallelism
in interface AccessExecutionJobVertex
public boolean isMaxParallelismConfigured()
public JobID getJobId()
public JobVertexID getJobVertexId()
AccessExecutionJobVertex
JobVertexID
for this job vertex.getJobVertexId
in interface AccessExecutionJobVertex
public ExecutionVertex[] getTaskVertices()
AccessExecutionJobVertex
getTaskVertices
in interface AccessExecutionJobVertex
public IntermediateResult[] getProducedDataSets()
public InputSplitAssigner getSplitAssigner()
public SlotSharingGroup getSlotSharingGroup()
public CoLocationGroup getCoLocationGroup()
public List<IntermediateResult> getInputs()
public SerializedValue<TaskInformation> getSerializedTaskInformation() throws IOException
IOException
public boolean isInFinalState()
public ExecutionState getAggregateState()
AccessExecutionJobVertex
ExecutionState
for this job vertex.getAggregateState
in interface AccessExecutionJobVertex
public void connectToPredecessors(Map<IntermediateDataSetID,IntermediateResult> intermediateDataSets) throws JobException
JobException
public void scheduleAll(SlotProvider slotProvider, boolean queued) throws NoResourceAvailableException
NoResourceAvailableException
public void cancel()
public void fail(Throwable t)
public void waitForAllVerticesToReachFinishingState() throws InterruptedException
InterruptedException
public void resetForNewExecution()
public StringifiedAccumulatorResult[] getAggregatedUserAccumulatorsStringified()
AccessExecutionJobVertex
getAggregatedUserAccumulatorsStringified
in interface AccessExecutionJobVertex
public static ExecutionState getAggregateJobVertexState(int[] verticesPerState, int parallelism)
public static Map<JobVertexID,ExecutionJobVertex> includeLegacyJobVertexIDs(Map<JobVertexID,ExecutionJobVertex> tasks)
public ArchivedExecutionJobVertex archive()
archive
in interface Archiveable<ArchivedExecutionJobVertex>
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.