public interface LineageMeta extends AutoCloseable
Modifier and Type | Method and Description |
---|---|
void |
deleteSinkTableLineage(String job)
Delete the sink table lineage for given job.
|
void |
deleteSourceTableLineage(String job)
Delete the source table lineage for given job.
|
void |
saveSinkDataLineage(DataLineageEntity entity)
Save the sink table and job lineage.
|
void |
saveSinkTableLineage(TableLineageEntity entity)
Save the sink table and job lineage.
|
void |
saveSourceDataLineage(DataLineageEntity entity)
Save the source table and job lineage.
|
void |
saveSourceTableLineage(TableLineageEntity entity)
Save the source table and job lineage.
|
Iterator<DataLineageEntity> |
sinkDataLineages(Predicate predicate)
Get sink data and job lineages.
|
Iterator<TableLineageEntity> |
sinkTableLineages(Predicate predicate)
Get sink table and job lineages.
|
Iterator<DataLineageEntity> |
sourceDataLineages(Predicate predicate)
Get source data and job lineages.
|
Iterator<TableLineageEntity> |
sourceTableLineages(Predicate predicate)
Get source table and job lineages.
|
close
void saveSourceTableLineage(TableLineageEntity entity)
entity
- the table lineage entityvoid deleteSourceTableLineage(String job)
job
- the job for table lineageIterator<TableLineageEntity> sourceTableLineages(@Nullable Predicate predicate)
predicate
- the predicate for the table lineagesvoid saveSinkTableLineage(TableLineageEntity entity)
entity
- the table lineage entityIterator<TableLineageEntity> sinkTableLineages(@Nullable Predicate predicate)
predicate
- the predicate for the table lineagesvoid deleteSinkTableLineage(String job)
job
- the job for table lineagevoid saveSourceDataLineage(DataLineageEntity entity)
entity
- the data lineage entityIterator<DataLineageEntity> sourceDataLineages(@Nullable Predicate predicate)
predicate
- the predicate for the table lineagesvoid saveSinkDataLineage(DataLineageEntity entity)
entity
- the data lineage entityIterator<DataLineageEntity> sinkDataLineages(@Nullable Predicate predicate)
predicate
- the predicate for the table lineagesCopyright © 2023–2024 The Apache Software Foundation. All rights reserved.