Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion airflow/providers/google/cloud/transfers/mssql_to_gcs.py
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@

class MSSQLToGCSOperator(BaseSQLToGCSOperator):
"""Copy data from Microsoft SQL Server to Google Cloud Storage
in JSON or CSV format.
in JSON, CSV or Parquet format.

:param mssql_conn_id: Reference to a specific MSSQL hook.

Expand Down
2 changes: 1 addition & 1 deletion airflow/providers/google/cloud/transfers/mysql_to_gcs.py
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@


class MySQLToGCSOperator(BaseSQLToGCSOperator):
"""Copy data from MySQL to Google Cloud Storage in JSON or CSV format.
"""Copy data from MySQL to Google Cloud Storage in JSON, CSV or Parquet format.

.. seealso::
For more information on how to use this operator, take a look at the guide:
Expand Down
2 changes: 1 addition & 1 deletion airflow/providers/google/cloud/transfers/oracle_to_gcs.py
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@


class OracleToGCSOperator(BaseSQLToGCSOperator):
"""Copy data from Oracle to Google Cloud Storage in JSON or CSV format.
"""Copy data from Oracle to Google Cloud Storage in JSON, CSV or Parquet format.

.. seealso::
For more information on how to use this operator, take a look at the guide:
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,7 @@ def description(self):

class PostgresToGCSOperator(BaseSQLToGCSOperator):
"""
Copy data from Postgres to Google Cloud Storage in JSON or CSV format.
Copy data from Postgres to Google Cloud Storage in JSON, CSV or Parquet format.

:param postgres_conn_id: Reference to a specific Postgres hook.
:param use_server_side_cursor: If server-side cursor should be used for querying postgres.
Expand Down
2 changes: 1 addition & 1 deletion airflow/providers/google/cloud/transfers/presto_to_gcs.py
Original file line number Diff line number Diff line change
Expand Up @@ -141,7 +141,7 @@ def __iter__(self) -> "_PrestoToGCSPrestoCursorAdapter":


class PrestoToGCSOperator(BaseSQLToGCSOperator):
"""Copy data from PrestoDB to Google Cloud Storage in JSON or CSV format.
"""Copy data from PrestoDB to Google Cloud Storage in JSON, CSV or Parquet format.

:param presto_conn_id: Reference to a specific Presto hook.
"""
Expand Down
4 changes: 2 additions & 2 deletions airflow/providers/google/cloud/transfers/sql_to_gcs.py
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@

class BaseSQLToGCSOperator(BaseOperator):
"""
Copy data from SQL to Google Cloud Storage in JSON or CSV format.
Copy data from SQL to Google Cloud Storage in JSON, CSV, or Parquet format.

:param sql: The SQL to execute.
:param bucket: The bucket to upload to.
Expand All @@ -50,7 +50,7 @@ class BaseSQLToGCSOperator(BaseOperator):
filename param docs above). This param allows developers to specify the
file size of the splits. Check https://cloud.google.com/storage/quotas
to see the maximum allowed file size for a single object.
:param export_format: Desired format of files to be exported.
:param export_format: Desired format of files to be exported. (json, csv or parquet)
:param field_delimiter: The delimiter to be used for CSV files.
:param null_marker: The null marker to be used for CSV files.
:param gzip: Option to compress file for upload (does not apply to schemas).
Expand Down
2 changes: 1 addition & 1 deletion airflow/providers/google/cloud/transfers/trino_to_gcs.py
Original file line number Diff line number Diff line change
Expand Up @@ -141,7 +141,7 @@ def __iter__(self) -> "_TrinoToGCSTrinoCursorAdapter":


class TrinoToGCSOperator(BaseSQLToGCSOperator):
"""Copy data from TrinoDB to Google Cloud Storage in JSON or CSV format.
"""Copy data from TrinoDB to Google Cloud Storage in JSON, CSV or Parquet format.

:param trino_conn_id: Reference to a specific Trino hook.
"""
Expand Down