DefaultSourceLineageVertex (Flink : 2.0-SNAPSHOT API)

java.lang.Object
- org.apache.flink.streaming.api.lineage.DefaultSourceLineageVertex

All Implemented Interfaces:

LineageVertex, SourceLineageVertex
```
@Internal
public class DefaultSourceLineageVertex
extends Object
implements SourceLineageVertex
```
Default implementation for SourceLineageVertex.

Constructor Summary

Constructors
Constructor Description

DefaultSourceLineageVertex(Boundedness boundedness)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`addDataset(LineageDataset lineageDataset)`
`Boundedness`	`boundedness()`	The boundedness for the source connector, users can get boundedness for each sources in the lineage and determine the job execution mode with RuntimeExecutionMode.
`List<LineageDataset>`	`datasets()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - DefaultSourceLineageVertex
```
public DefaultSourceLineageVertex(Boundedness boundedness)
```
- Method Detail
  - addDataset
```
public void addDataset(LineageDataset lineageDataset)
```
  - datasets
```
public List<LineageDataset> datasets()
```
    Specified by:
    
    datasets in interface LineageVertex
  - boundedness
```
public Boundedness boundedness()
```
    Description copied from interface: SourceLineageVertex
    
    The boundedness for the source connector, users can get boundedness for each sources in the lineage and determine the job execution mode with RuntimeExecutionMode.
    
    Specified by:
    
    boundedness in interface SourceLineageVertex