public class ExecutionVertex extends Object implements Serializable
Execution
.Constructor and Description |
---|
ExecutionVertex(ExecutionJobVertex jobVertex,
int subTaskIndex,
IntermediateResult[] producedDataSets,
scala.concurrent.duration.FiniteDuration timeout) |
ExecutionVertex(ExecutionJobVertex jobVertex,
int subTaskIndex,
IntermediateResult[] producedDataSets,
scala.concurrent.duration.FiniteDuration timeout,
int maxPriorExecutionHistoryLength) |
ExecutionVertex(ExecutionJobVertex jobVertex,
int subTaskIndex,
IntermediateResult[] producedDataSets,
scala.concurrent.duration.FiniteDuration timeout,
long createTimestamp,
int maxPriorExecutionHistoryLength) |
public ExecutionVertex(ExecutionJobVertex jobVertex, int subTaskIndex, IntermediateResult[] producedDataSets, scala.concurrent.duration.FiniteDuration timeout)
public ExecutionVertex(ExecutionJobVertex jobVertex, int subTaskIndex, IntermediateResult[] producedDataSets, scala.concurrent.duration.FiniteDuration timeout, int maxPriorExecutionHistoryLength)
public ExecutionVertex(ExecutionJobVertex jobVertex, int subTaskIndex, IntermediateResult[] producedDataSets, scala.concurrent.duration.FiniteDuration timeout, long createTimestamp, int maxPriorExecutionHistoryLength)
public JobID getJobId()
public ExecutionJobVertex getJobVertex()
public JobVertexID getJobvertexId()
public String getTaskName()
public String getTaskNameWithSubtaskIndex()
public int getTotalNumberOfParallelSubtasks()
public int getParallelSubtaskIndex()
public int getNumberOfInputs()
public ExecutionEdge[] getInputEdges(int input)
public CoLocationConstraint getLocationConstraint()
public Execution getCurrentExecutionAttempt()
public ExecutionState getExecutionState()
public long getStateTimestamp(ExecutionState state)
public Throwable getFailureCause()
public SimpleSlot getCurrentAssignedResource()
public InstanceConnectionInfo getCurrentAssignedResourceLocation()
public Execution getPriorExecutionAttempt(int attemptNumber)
public ExecutionGraph getExecutionGraph()
public Map<IntermediateResultPartitionID,IntermediateResultPartition> getProducedPartitions()
public void connectSource(int inputNumber, IntermediateResult source, JobEdge edge, int consumerNumber)
public void setScheduleLocalOnly(boolean scheduleLocalOnly)
public boolean isScheduleLocalOnly()
public Iterable<Instance> getPreferredLocations()
null
to indicate no location preference.public void resetForNewExecution()
public boolean scheduleForExecution(Scheduler scheduler, boolean queued) throws NoResourceAvailableException
NoResourceAvailableException
public void deployToSlot(SimpleSlot slot) throws JobException
JobException
public void cancel()
public void stop()
public void fail(Throwable t)
public boolean sendMessageToCurrentExecution(Serializable message, ExecutionAttemptID attemptID)
public boolean sendMessageToCurrentExecution(Serializable message, ExecutionAttemptID attemptID, ActorGateway sender)
public void prepareForArchiving() throws IllegalStateException
IllegalStateException
public void cachePartitionInfo(PartialInputChannelDeploymentDescriptor partitionInfo)
public String getSimpleName()
getTaskName()
, 'x' is the parallel
subtask index as returned by getParallelSubtaskIndex()
+ 1
, and 'y' is the total
number of tasks, as returned by getTotalNumberOfParallelSubtasks()
.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.