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

Module Contents¶

class airflow.providers.google.cloud.transfers.trino_to_gcs.TrinoToGCSOperator(*, trino_conn_id: str = '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)[source]¶

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

Parameters

value (Any) -- Trino column value
schema_type (str) -- BigQuery data type

Was this entry helpful?