guotongfei commented on a change in pull request #18755:
URL: https://github.com/apache/airflow/pull/18755#discussion_r722813490
##########
File path: airflow/providers/amazon/aws/transfers/mysql_to_s3.py
##########
@@ -82,6 +86,8 @@ def __init__(
pd_csv_kwargs: Optional[dict] = None,
index: bool = False,
header: bool = False,
+ file_format: str = 'csv',
Review comment:
Done
##########
File path: airflow/providers/amazon/aws/transfers/mysql_to_s3.py
##########
@@ -60,6 +60,10 @@ class MySQLToS3Operator(BaseOperator):
:type index: str
:param header: whether to include header or not into the S3 file
:type header: bool
+ :param file_format: the destination file format, only csv and parquet are
supported.
+ :type file_format: str
+ :param pd_parquet_kwargs: arguments to include in pd.to_parquet
+ :type pd_parquet_kwargs: dict
Review comment:
Updated
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
