MetaDataProvider

sqllineage.core.metadata_provider.MetaDataProvider

class sqllineage.core.metadata_provider.MetaDataProvider

Base class used to provide metadata like table schema.

When parse below sql:

INSERT INTO db1.table1
SELECT c1
FROM db2.table2 t2
JOIN db3.table3 t3 ON t2.id = t3.id

Only by literal analysis, we don’t know which table is selected column c1 from. A subclass of MetaDataProvider implementing _get_table_columns passing to sqllineage.runner.LineageRunner. can help parse column lineage correctly.

get_table_columns(table: Table, **kwargs) → List[Column]

return columns of given table.

register_session_metadata(table: Table, columns: List[Column]) → None

Register session-level metadata, like temporary table or view created.

deregister_session_metadata() → None

Deregister session-level metadata.