airflow.providers.google.cloud.transfers.trino_to_gcs

Module Contents

Classes

TrinoToGCSOperator

Copy data from TrinoDB to Google Cloud Storage in JSON or CSV format.
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 or CSV format.

Parameters

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

ui_color = #a0e08c[source]
type_map[source]
query(self)[source]

Queries trino and returns a cursor to the results.

field_to_bigquery(self, field)[source]

Convert trino field type to BigQuery field type.

convert_type(self, 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

Was this entry helpful?