org.apache.flink.runtime.jobgraph

Class JobEdge

java.lang.Object

org.apache.flink.runtime.jobgraph.JobEdge

All Implemented Interfaces:

Serializable

public class JobEdge
extends Object
implements Serializable

This class represent edges (communication channels) in a job graph. The edges always go from an intermediate result partition to a job vertex. An edge is parametrized with its DistributionPattern.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
JobEdge(IntermediateDataSetID sourceId, JobVertex target, DistributionPattern distributionPattern) Constructs a new job edge that refers to an intermediate result via the Id, rather than directly through the intermediate data set structure.
JobEdge(IntermediateDataSet source, JobVertex target, DistributionPattern distributionPattern) Constructs a new job edge, that connects an intermediate result to a consumer task.

Method Summary

Modifier and Type	Method and Description
void	connecDataSet(IntermediateDataSet dataSet)
DistributionPattern	getDistributionPattern() Returns the distribution pattern used for this edge.
String	getOperatorLevelCachingDescription() Gets the operator-level caching description for this input.
String	getPreProcessingOperationName() Gets the name of the pro-processing operation for this input.
String	getShipStrategyName() Gets the name of the ship strategy for the represented input, like "forward", "partition hash", "rebalance", "broadcast", ...
IntermediateDataSet	getSource() Returns the data set at the source of the edge.
IntermediateDataSetID	getSourceId() Gets the ID of the consumed data set.
JobVertex	getTarget() Returns the vertex connected to this edge.
boolean	isIdReference()
void	setOperatorLevelCachingDescription(String operatorLevelCachingDescription) Sets the operator-level caching description for this input.
void	setPreProcessingOperationName(String preProcessingOperationName) Sets the name of the pre-processing operation for this input.
void	setShipStrategyName(String shipStrategyName) Sets the name of the ship strategy for the represented input.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

JobEdge

public JobEdge(IntermediateDataSet source,
               JobVertex target,
               DistributionPattern distributionPattern)

Constructs a new job edge, that connects an intermediate result to a consumer task.

Parameters:

source - The data set that is at the source of this edge.

target - The operation that is at the target of this edge.

distributionPattern - The pattern that defines how the connection behaves in parallel.

JobEdge

public JobEdge(IntermediateDataSetID sourceId,
               JobVertex target,
               DistributionPattern distributionPattern)

Constructs a new job edge that refers to an intermediate result via the Id, rather than directly through the intermediate data set structure.

Parameters:

sourceId - The id of the data set that is at the source of this edge.

target - The operation that is at the target of this edge.

distributionPattern - The pattern that defines how the connection behaves in parallel.

Method Detail

getSource

public IntermediateDataSet getSource()

Returns the data set at the source of the edge. May be null, if the edge refers to the source via an ID and has not been connected.

Returns:

The data set at the source of the edge

getTarget

public JobVertex getTarget()

Returns the vertex connected to this edge.

Returns:

The vertex connected to this edge.

getDistributionPattern

public DistributionPattern getDistributionPattern()

Returns the distribution pattern used for this edge.

Returns:

The distribution pattern used for this edge.

getSourceId

public IntermediateDataSetID getSourceId()

Gets the ID of the consumed data set.

Returns:

The ID of the consumed data set.

isIdReference

public boolean isIdReference()

connecDataSet

public void connecDataSet(IntermediateDataSet dataSet)

getShipStrategyName

public String getShipStrategyName()

Gets the name of the ship strategy for the represented input, like "forward", "partition hash", "rebalance", "broadcast", ...

Returns:

The name of the ship strategy for the represented input, or null, if none was set.

setShipStrategyName

public void setShipStrategyName(String shipStrategyName)

Sets the name of the ship strategy for the represented input.

Parameters:

shipStrategyName - The name of the ship strategy.

getPreProcessingOperationName

public String getPreProcessingOperationName()

Gets the name of the pro-processing operation for this input.

Returns:

The name of the pro-processing operation, or null, if none was set.

setPreProcessingOperationName

public void setPreProcessingOperationName(String preProcessingOperationName)

Sets the name of the pre-processing operation for this input.

Parameters:

preProcessingOperationName - The name of the pre-processing operation.

getOperatorLevelCachingDescription

public String getOperatorLevelCachingDescription()

Gets the operator-level caching description for this input.

Returns:

The description of operator-level caching, or null, is none was set.

setOperatorLevelCachingDescription

public void setOperatorLevelCachingDescription(String operatorLevelCachingDescription)

Sets the operator-level caching description for this input.

Parameters:

operatorLevelCachingDescription - The description of operator-level caching.

toString

public String toString()

Overrides:

toString in class Object