Airflow Summit 2025 is coming October 07-09. Register now for early bird ticket!

airflow.providers.google.cloud.transfers.trino_to_gcs¶

Classes¶

TrinoToGCSOperator

Copy data from TrinoDB to Google Cloud Storage in JSON, CSV or Parquet format.

Module Contents¶

class airflow.providers.google.cloud.transfers.trino_to_gcs.TrinoToGCSOperator(*, trino_conn_id='trino_default', **kwargs)[source]¶

Bases: airflow.providers.google.cloud.transfers.sql_to_gcs.BaseSQLToGCSOperator

Copy data from TrinoDB to Google Cloud Storage in JSON, CSV or Parquet format.

Parameters:

trino_conn_id (str) – Reference to a specific Trino hook.

ui_color = '#a0e08c'[source]¶
type_map[source]¶
trino_conn_id = 'trino_default'[source]¶
property db_hook: airflow.providers.trino.hooks.trino.TrinoHook[source]¶
query()[source]¶

Query trino and returns a cursor to the results.

field_to_bigquery(field)[source]¶

Convert trino field type to BigQuery field type.

convert_type(value, schema_type, **kwargs)[source]¶

Do nothing. Trino uses JSON on the transport layer, so types are simple.

Parameters:

  • value – Trino column value

  • schema_type – BigQuery data type

get_openlineage_facets_on_start()[source]¶

Was this entry helpful?