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.