airflow.providers.google.cloud.utils.openlineage¶
This module contains code related to OpenLineage and lineage extraction.
Module Contents¶
Functions¶
|
Get facets from BigQuery table object. |
|
Get column lineage facet. |
- airflow.providers.google.cloud.utils.openlineage.get_facets_from_bq_table(table)[source]¶
Get facets from BigQuery table object.
- airflow.providers.google.cloud.utils.openlineage.get_identity_column_lineage_facet(field_names, input_datasets)[source]¶
Get column lineage facet.
Simple lineage will be created, where each source column corresponds to single destination column in each input dataset and there are no transformations made.