public class SourceTableLineageTable extends TableLineageTable
For example: If we select * from sys.source_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.
TableLineageTable.TableLineageRead
Modifier and Type | Field and Description |
---|---|
static String |
SOURCE_TABLE_LINEAGE |
lineageMetaFactory, options, TABLE_TYPE
Constructor and Description |
---|
SourceTableLineageTable(LineageMetaFactory lineageMetaFactory,
Options options) |
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() |
newScan, primaryKeys, rowType
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
comment, createBranch, createBranch, createTag, createTag, createTag, createTag, deleteBranch, deleteTag, fastForward, indexManifestFileReader, latestSnapshotId, manifestFileReader, manifestListReader, newBatchWriteBuilder, newCommit, newExpireChangelog, newExpireSnapshots, newStreamScan, newStreamWriteBuilder, newWrite, newWriteSelector, options, partitionKeys, renameTag, replaceTag, rollbackTo, rollbackTo, snapshot, statistics
newReadBuilder
deleteBranches, deleteTags, fullName, uuid
public static final String SOURCE_TABLE_LINEAGE
public SourceTableLineageTable(LineageMetaFactory lineageMetaFactory, Options options)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.