org.apache.paimon.table.system

Class SinkTableLineageTable

java.lang.Object

org.apache.paimon.table.system.TableLineageTable

org.apache.paimon.table.system.SinkTableLineageTable

All Implemented Interfaces:

Serializable, InnerTable, ReadonlyTable, Table

public class SinkTableLineageTable
extends TableLineageTable

This is a system table to display all the sink table lineages.

  For example:
     If we select * from sys.sink_table_lineage, we will get
     database_name       table_name       job_name      create_time
        default            test0            job1    2023-10-22 20:35:12
       database1           test1            job1    2023-10-28 21:35:52
          ...               ...             ...             ...
     We can write sql to fetch the information we need.
 

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.paimon.table.system.TableLineageTable

TableLineageTable.TableLineageRead

Field Summary

Fields

Modifier and Type	Field and Description
static String	SINK_TABLE_LINEAGE

Fields inherited from class org.apache.paimon.table.system.TableLineageTable

lineageMetaFactory, options

Constructor Summary

Constructors

Constructor and Description
SinkTableLineageTable(LineageMetaFactory lineageMetaFactory, Options options)

Method Summary

Modifier and Type	Method and Description
Table	copy(Map<String,String> dynamicOptions) Copy this table with adding dynamic options.
String	name() A name to identify this table.
InnerTableRead	newRead()

Methods inherited from class org.apache.paimon.table.system.TableLineageTable

newScan, primaryKeys, rowType

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

newReadBuilder

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

deleteBranches, deleteTags, fullName

Field Detail

SINK_TABLE_LINEAGE

public static final String SINK_TABLE_LINEAGE

See Also:

Constant Field Values

Constructor Detail

SinkTableLineageTable

public SinkTableLineageTable(LineageMetaFactory lineageMetaFactory,
                             Options options)

Method Detail

newRead

public InnerTableRead newRead()

name

public String name()

Description copied from interface: Table

A name to identify this table.

copy

public Table copy(Map<String,String> dynamicOptions)

Description copied from interface: Table

Copy this table with adding dynamic options.