airflow.providers.apache.hive.assets.hive¶

Functions¶

`sanitize_uri`(uri)
`create_asset`(*, host, database, table[, port, extra])
`convert_asset_to_openlineage`(asset, lineage_context)	Translate Asset with valid AIP-60 uri to OpenLineage with assistance from the hook.

airflow.providers.apache.hive.assets.hive.sanitize_uri(uri)[source]¶

airflow.providers.apache.hive.assets.hive.create_asset(*, host, database, table, port=10000, extra=None)[source]¶

airflow.providers.apache.hive.assets.hive.convert_asset_to_openlineage(asset, lineage_context)[source]¶

Translate Asset with valid AIP-60 uri to OpenLineage with assistance from the hook.