| Package | Description |
|---|---|
| org.apache.paimon.lineage | |
| org.apache.paimon.table.system |
| Modifier and Type | Interface and Description |
|---|---|
interface |
DataLineageEntity
Data lineage entity with table lineage, barrier id and snapshot id for table source and sink
lineage.
|
| Modifier and Type | Class and Description |
|---|---|
class |
TableLineageEntityImpl
Default implementation for
TableLineageEntity. |
| Modifier and Type | Method and Description |
|---|---|
Iterator<TableLineageEntity> |
LineageMeta.sinkTableLineages(Predicate predicate)
Get sink table and job lineages.
|
Iterator<TableLineageEntity> |
LineageMeta.sourceTableLineages(Predicate predicate)
Get source table and job lineages.
|
| Modifier and Type | Method and Description |
|---|---|
void |
LineageMeta.saveSinkTableLineage(TableLineageEntity entity)
Save the sink table and job lineage.
|
void |
LineageMeta.saveSourceTableLineage(TableLineageEntity entity)
Save the source table and job lineage.
|
| Constructor and Description |
|---|
TableLineageRead(LineageMetaFactory lineageMetaFactory,
Options options,
java.util.function.BiFunction<LineageMeta,Predicate,Iterator<TableLineageEntity>> tableLineageQuery) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.