public class ExecutionJobVertex extends Object implements Serializable
Modifier and Type | Class and Description |
---|---|
static class |
ExecutionJobVertex.PredeterminedInputSplitAssigner
An InputSplitAssigner that assigns to pre-determined hosts.
|
Constructor and Description |
---|
ExecutionJobVertex(ExecutionGraph graph,
JobVertex jobVertex,
int defaultParallelism,
scala.concurrent.duration.FiniteDuration timeout) |
ExecutionJobVertex(ExecutionGraph graph,
JobVertex jobVertex,
int defaultParallelism,
scala.concurrent.duration.FiniteDuration timeout,
long createTimestamp) |
public ExecutionJobVertex(ExecutionGraph graph, JobVertex jobVertex, int defaultParallelism, scala.concurrent.duration.FiniteDuration timeout) throws JobException
JobException
public ExecutionJobVertex(ExecutionGraph graph, JobVertex jobVertex, int defaultParallelism, scala.concurrent.duration.FiniteDuration timeout, long createTimestamp) throws JobException
JobException
public ExecutionGraph getGraph()
public JobVertex getJobVertex()
public int getParallelism()
public JobID getJobId()
public JobVertexID getJobVertexId()
public ExecutionVertex[] getTaskVertices()
public IntermediateResult[] getProducedDataSets()
public InputSplitAssigner getSplitAssigner()
public SlotSharingGroup getSlotSharingGroup()
public CoLocationGroup getCoLocationGroup()
public List<IntermediateResult> getInputs()
public boolean isInFinalState()
public ExecutionState getAggregateState()
public void connectToPredecessors(Map<IntermediateDataSetID,IntermediateResult> intermediateDataSets) throws JobException
JobException
public void scheduleAll(Scheduler scheduler, boolean queued) throws NoResourceAvailableException
NoResourceAvailableException
public void cancel()
public void fail(Throwable t)
public void waitForAllVerticesToReachFinishingState() throws InterruptedException
InterruptedException
public void resetForNewExecution()
public void prepareForArchiving()
public Map<AccumulatorRegistry.Metric,Accumulator<?,?>> getAggregatedMetricAccumulators()
public StringifiedAccumulatorResult[] getAggregatedUserAccumulatorsStringified()
public static ExecutionState getAggregateJobVertexState(int[] verticesPerState, int parallelism)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.