org.apache.flink.runtime.executiongraph

Class ExecutionVertex

java.lang.Object

org.apache.flink.runtime.executiongraph.ExecutionVertex

All Implemented Interfaces:

Serializable

public class ExecutionVertex
extends Object
implements Serializable

The ExecutionVertex is a parallel subtask of the execution. It may be executed once, or several times, each of which time it spawns an Execution.

See Also:

Serialized Form

Constructor Summary

Constructors

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, long createTimestamp)

Method Summary

Modifier and Type	Method and Description
void	cachePartitionInfo(PartialInputChannelDeploymentDescriptor partitionInfo)
void	cancel()
void	connectSource(int inputNumber, IntermediateResult source, JobEdge edge, int consumerNumber)
void	deployToSlot(SimpleSlot slot)
void	fail(Throwable t)
SimpleSlot	getCurrentAssignedResource()
InstanceConnectionInfo	getCurrentAssignedResourceLocation()
Execution	getCurrentExecutionAttempt()
ExecutionGraph	getExecutionGraph()
ExecutionState	getExecutionState()
Throwable	getFailureCause()
ExecutionEdge[]	getInputEdges(int input)
JobID	getJobId()
ExecutionJobVertex	getJobVertex()
JobVertexID	getJobvertexId()
CoLocationConstraint	getLocationConstraint()
int	getNumberOfInputs()
StateHandle	getOperatorState()
int	getParallelSubtaskIndex()
Iterable<Instance>	getPreferredLocations() Gets the location preferences of this task, determined by the locations of the predecessors from which it receives input data.
String	getSimpleName() Creates a simple name representation in the style 'taskname (x/y)', where 'taskname' is the name as returned by getTaskName(), 'x' is the parallel subtask index as returned by getParallelSubtaskIndex()+ 1, and 'y' is the total number of tasks, as returned by getTotalNumberOfParallelSubtasks().
long	getStateTimestamp(ExecutionState state)
String	getTaskName()
String	getTaskNameWithSubtaskIndex()
int	getTotalNumberOfParallelSubtasks()
boolean	isScheduleLocalOnly()
void	prepareForArchiving() This method cleans fields that are irrelevant for the archived execution attempt.
void	resetForNewExecution()
boolean	scheduleForExecution(Scheduler scheduler, boolean queued)
void	setLocationConstraintHosts(List<Instance> instances)
void	setOperatorState(StateHandle operatorState)
void	setScheduleLocalOnly(boolean scheduleLocalOnly)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ExecutionVertex

public ExecutionVertex(ExecutionJobVertex jobVertex,
                       int subTaskIndex,
                       IntermediateResult[] producedDataSets,
                       scala.concurrent.duration.FiniteDuration timeout)

ExecutionVertex

public ExecutionVertex(ExecutionJobVertex jobVertex,
                       int subTaskIndex,
                       IntermediateResult[] producedDataSets,
                       scala.concurrent.duration.FiniteDuration timeout,
                       long createTimestamp)

Method Detail

getJobId

public JobID getJobId()

getJobVertex

public ExecutionJobVertex getJobVertex()

getJobvertexId

public JobVertexID getJobvertexId()

getTaskName

public String getTaskName()

getTaskNameWithSubtaskIndex

public String getTaskNameWithSubtaskIndex()

getTotalNumberOfParallelSubtasks

public int getTotalNumberOfParallelSubtasks()

getParallelSubtaskIndex

public int getParallelSubtaskIndex()

getNumberOfInputs

public int getNumberOfInputs()

getInputEdges

public ExecutionEdge[] getInputEdges(int input)

getLocationConstraint

public CoLocationConstraint getLocationConstraint()

getCurrentExecutionAttempt

public Execution getCurrentExecutionAttempt()

getExecutionState

public ExecutionState getExecutionState()

getStateTimestamp

public long getStateTimestamp(ExecutionState state)

getFailureCause

public Throwable getFailureCause()

getCurrentAssignedResource

public SimpleSlot getCurrentAssignedResource()

getCurrentAssignedResourceLocation

public InstanceConnectionInfo getCurrentAssignedResourceLocation()

setOperatorState

public void setOperatorState(StateHandle operatorState)

getOperatorState

public StateHandle getOperatorState()

getExecutionGraph

public ExecutionGraph getExecutionGraph()

connectSource

public void connectSource(int inputNumber,
                          IntermediateResult source,
                          JobEdge edge,
                          int consumerNumber)

setLocationConstraintHosts

public void setLocationConstraintHosts(List<Instance> instances)

setScheduleLocalOnly

public void setScheduleLocalOnly(boolean scheduleLocalOnly)

isScheduleLocalOnly

public boolean isScheduleLocalOnly()

getPreferredLocations

public Iterable<Instance> getPreferredLocations()

Gets the location preferences of this task, determined by the locations of the predecessors from which it receives input data. If there are more than MAX_DISTINCT_LOCATIONS_TO_CONSIDER different locations of source data, this method returns null to indicate no location preference.

Returns:

The preferred locations for this vertex execution, or null, if there is no preference.

resetForNewExecution

public void resetForNewExecution()

scheduleForExecution

public boolean scheduleForExecution(Scheduler scheduler,
                                    boolean queued)
                             throws NoResourceAvailableException

Throws:

NoResourceAvailableException

deployToSlot

public void deployToSlot(SimpleSlot slot)
                  throws JobException

Throws:

JobException

cancel

public void cancel()

fail

public void fail(Throwable t)

prepareForArchiving

public void prepareForArchiving()
                         throws IllegalStateException

This method cleans fields that are irrelevant for the archived execution attempt.

Throws:

IllegalStateException

cachePartitionInfo

public void cachePartitionInfo(PartialInputChannelDeploymentDescriptor partitionInfo)

getSimpleName

public String getSimpleName()

Creates a simple name representation in the style 'taskname (x/y)', where 'taskname' is the name as returned by getTaskName(), 'x' is the parallel subtask index as returned by getParallelSubtaskIndex()+ 1, and 'y' is the total number of tasks, as returned by getTotalNumberOfParallelSubtasks().

Returns:

A simple name representation.

toString

public String toString()

Overrides:

toString in class Object