| :py:mod:`airflow.providers.google.cloud.transfers.trino_to_gcs` |
| =============================================================== |
| |
| .. py:module:: airflow.providers.google.cloud.transfers.trino_to_gcs |
| |
| |
| Module Contents |
| --------------- |
| |
| Classes |
| ~~~~~~~ |
| |
| .. autoapisummary:: |
| |
| airflow.providers.google.cloud.transfers.trino_to_gcs.TrinoToGCSOperator |
| |
| |
| |
| |
| .. py:class:: TrinoToGCSOperator(*, trino_conn_id = 'trino_default', **kwargs) |
| |
| Bases: :py:obj:`airflow.providers.google.cloud.transfers.sql_to_gcs.BaseSQLToGCSOperator` |
| |
| Copy data from TrinoDB to Google Cloud Storage in JSON or CSV format. |
| |
| :param trino_conn_id: Reference to a specific Trino hook. |
| |
| .. py:attribute:: ui_color |
| :annotation: = #a0e08c |
| |
| |
| |
| .. py:attribute:: type_map |
| |
| |
| |
| |
| .. py:method:: query(self) |
| |
| Queries trino and returns a cursor to the results. |
| |
| |
| .. py:method:: field_to_bigquery(self, field) |
| |
| Convert trino field type to BigQuery field type. |
| |
| |
| .. py:method:: convert_type(self, value, schema_type, **kwargs) |
| |
| Do nothing. Trino uses JSON on the transport layer, so types are simple. |
| |
| :param value: Trino column value |
| :param schema_type: BigQuery data type |
| |
| |
| |
