Class DefaultLogicalEdge
- java.lang.Object
-
- org.apache.flink.runtime.jobgraph.topology.DefaultLogicalEdge
-
- All Implemented Interfaces:
LogicalEdge
public class DefaultLogicalEdge extends Object implements LogicalEdge
Default implementation ofLogicalEdge
. It is an adapter ofJobEdge
.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description DistributionPattern
getDistributionPattern()
Returns the distribution pattern used for this edge.JobVertexID
getProducerVertexId()
Returns the ID of producer vertex.
-
-
-
Method Detail
-
getDistributionPattern
public DistributionPattern getDistributionPattern()
Description copied from interface:LogicalEdge
Returns the distribution pattern used for this edge.- Specified by:
getDistributionPattern
in interfaceLogicalEdge
-
getProducerVertexId
public JobVertexID getProducerVertexId()
Description copied from interface:LogicalEdge
Returns the ID of producer vertex.- Specified by:
getProducerVertexId
in interfaceLogicalEdge
-
-