dlt.destinations.impl.bigquery.bigquery
BigQueryLoadJob Objects
class BigQueryLoadJob(_BigQueryLoadJobBase, HasFollowupJobs)
Per-file load job. Completing it triggers the table-chain followup hook.
BigQueryAtomicReplaceLoadJob Objects
class BigQueryAtomicReplaceLoadJob(_BigQueryLoadJobBase)
Aggregated atomic replace job. Not HasFollowupJobs so completing it never re-fires the
table-chain hook.
BigQueryClient Objects
class BigQueryClient(SqlJobClientWithStagingDataset,
SupportsStagingDestination)
get_storage_tables
def get_storage_tables(
table_names: Iterable[str]
) -> Iterable[Tuple[str, TTableSchemaColumns]]
Gets table schemas from BigQuery using INFORMATION_SCHEMA or get_table for hidden datasets