Class DefaultLineageVertex
- java.lang.Object
-
- org.apache.flink.streaming.api.lineage.DefaultLineageVertex
-
- All Implemented Interfaces:
LineageVertex
@Internal public class DefaultLineageVertex extends Object implements LineageVertex
Default implementation forLineageVertex
.
-
-
Constructor Summary
Constructors Constructor Description DefaultLineageVertex()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addLineageDataset(LineageDataset lineageDataset)
List<LineageDataset>
datasets()
-
-
-
Method Detail
-
addLineageDataset
public void addLineageDataset(LineageDataset lineageDataset)
-
datasets
public List<LineageDataset> datasets()
- Specified by:
datasets
in interfaceLineageVertex
-
-