Package | Description |
---|---|
org.apache.paimon.lineage |
Modifier and Type | Method and Description |
---|---|
Iterator<DataLineageEntity> |
LineageMeta.sinkDataLineages(Predicate predicate)
Get sink data and job lineages.
|
Iterator<DataLineageEntity> |
LineageMeta.sourceDataLineages(Predicate predicate)
Get source data and job lineages.
|
Modifier and Type | Method and Description |
---|---|
void |
LineageMeta.saveSinkDataLineage(DataLineageEntity entity)
Save the sink table and job lineage.
|
void |
LineageMeta.saveSourceDataLineage(DataLineageEntity entity)
Save the source table and job lineage.
|
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.