Class TableLineageDatasetImpl
- java.lang.Object
-
- org.apache.flink.table.planner.lineage.TableLineageDatasetImpl
-
- All Implemented Interfaces:
LineageDataset
,TableLineageDataset
public class TableLineageDatasetImpl extends Object implements TableLineageDataset
Implementation for TableLineageDataSet.
-
-
Constructor Summary
Constructors Constructor Description TableLineageDatasetImpl(ContextResolvedTable contextResolvedTable, Optional<LineageDataset> lineageDatasetOpt)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addLineageDatasetFacet(LineageDatasetFacet facet)
CatalogContext
catalogContext()
Map<String,LineageDatasetFacet>
facets()
String
name()
String
namespace()
ObjectPath
objectPath()
CatalogBaseTable
table()
-
-
-
Constructor Detail
-
TableLineageDatasetImpl
public TableLineageDatasetImpl(ContextResolvedTable contextResolvedTable, Optional<LineageDataset> lineageDatasetOpt)
-
-
Method Detail
-
addLineageDatasetFacet
public void addLineageDatasetFacet(LineageDatasetFacet facet)
-
name
public String name()
- Specified by:
name
in interfaceLineageDataset
-
namespace
public String namespace()
- Specified by:
namespace
in interfaceLineageDataset
-
facets
public Map<String,LineageDatasetFacet> facets()
- Specified by:
facets
in interfaceLineageDataset
-
catalogContext
public CatalogContext catalogContext()
- Specified by:
catalogContext
in interfaceTableLineageDataset
-
table
public CatalogBaseTable table()
- Specified by:
table
in interfaceTableLineageDataset
-
objectPath
public ObjectPath objectPath()
- Specified by:
objectPath
in interfaceTableLineageDataset
-
-