Class DefaultLogicalVertex
- java.lang.Object
-
- org.apache.flink.runtime.jobgraph.topology.DefaultLogicalVertex
-
- All Implemented Interfaces:
LogicalVertex
,Vertex<JobVertexID,IntermediateDataSetID,LogicalVertex,LogicalResult>
public class DefaultLogicalVertex extends Object implements LogicalVertex
Default implementation ofLogicalVertex
. It is an adapter ofJobVertex
.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Iterable<DefaultLogicalResult>
getConsumedResults()
JobVertexID
getId()
Iterable<? extends LogicalEdge>
getInputs()
Get the inputLogicalEdge
s of the vertex.Iterable<DefaultLogicalResult>
getProducedResults()
-
-
-
Method Detail
-
getId
public JobVertexID getId()
- Specified by:
getId
in interfaceVertex<JobVertexID,IntermediateDataSetID,LogicalVertex,LogicalResult>
-
getConsumedResults
public Iterable<DefaultLogicalResult> getConsumedResults()
- Specified by:
getConsumedResults
in interfaceVertex<JobVertexID,IntermediateDataSetID,LogicalVertex,LogicalResult>
-
getProducedResults
public Iterable<DefaultLogicalResult> getProducedResults()
- Specified by:
getProducedResults
in interfaceVertex<JobVertexID,IntermediateDataSetID,LogicalVertex,LogicalResult>
-
getInputs
public Iterable<? extends LogicalEdge> getInputs()
Description copied from interface:LogicalVertex
Get the inputLogicalEdge
s of the vertex.- Specified by:
getInputs
in interfaceLogicalVertex
- Returns:
- the input
LogicalEdge
s
-
-