org.apache.paimon.table.system

Class TableLineageTable

java.lang.Object

org.apache.paimon.table.system.TableLineageTable

All Implemented Interfaces:

Serializable, InnerTable, ReadonlyTable, Table

Direct Known Subclasses:

SinkTableLineageTable, SourceTableLineageTable

public abstract class TableLineageTable
extends Object
implements ReadonlyTable

Base lineage table for source and sink table lineage.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	TableLineageTable.TableLineageRead Table lineage read with lineage meta query.

Field Summary

Fields

Modifier and Type	Field and Description
protected LineageMetaFactory	lineageMetaFactory
protected Options	options

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TableLineageTable(LineageMetaFactory lineageMetaFactory, Options options)

Method Summary

Modifier and Type	Method and Description
InnerTableScan	newScan()
List<String>	primaryKeys() Primary keys of this table.
RowType	rowType() Returns the row type of this table.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.paimon.table.ReadonlyTable

comment, createBranch, createBranch, createTag, createTag, createTag, createTag, deleteBranch, deleteTag, fastForward, indexManifestFileReader, latestSnapshotId, manifestFileReader, manifestListReader, newBatchWriteBuilder, newCommit, newExpireChangelog, newExpireSnapshots, newStreamScan, newStreamWriteBuilder, newWrite, newWriteSelector, options, partitionKeys, rollbackTo, rollbackTo, snapshot, statistics

Methods inherited from interface org.apache.paimon.table.InnerTable

newRead, newReadBuilder

Methods inherited from interface org.apache.paimon.table.Table

copy, deleteBranches, deleteTags, fullName, name

Field Detail

lineageMetaFactory

protected final LineageMetaFactory lineageMetaFactory

options

protected final Options options

Constructor Detail

TableLineageTable

protected TableLineageTable(LineageMetaFactory lineageMetaFactory,
                            Options options)

Method Detail

newScan

public InnerTableScan newScan()

Specified by:

newScan in interface InnerTable

rowType

public RowType rowType()

Description copied from interface: Table

Returns the row type of this table.

Specified by:

rowType in interface Table

primaryKeys

public List<String> primaryKeys()

Description copied from interface: Table

Primary keys of this table.

Specified by:

primaryKeys in interface Table