Lee-W commented on code in PR #37103:
URL: https://github.com/apache/airflow/pull/37103#discussion_r1482489398
##########
airflow/providers/microsoft/azure/transfers/local_to_adls.py:
##########
@@ -96,3 +96,53 @@ def execute(self, context: Context) -> None:
blocksize=self.blocksize,
**self.extra_upload_options,
)
+
+
+class DataToADLSOperator(BaseOperator):
+ """
+ Upload data to Azure Data Lake.
+
+ .. seealso::
+ For more information on how to use this operator, take a look at the
guide:
+ :ref:`howto/operator:DataToADLSOperator`
+
+ :param file_system_name: Name of the file system or instance of
FileSystemProperties.
+ :param file_name: Name of the file which needs to be created in the file
system.
+ :param data: Number of threads to use. If None, uses the number of cores.
Review Comment:
The docstring here seems to be wrong
##########
airflow/providers/microsoft/azure/transfers/local_to_adls.py:
##########
@@ -96,3 +96,53 @@ def execute(self, context: Context) -> None:
blocksize=self.blocksize,
**self.extra_upload_options,
)
+
+
+class DataToADLSOperator(BaseOperator):
+ """
+ Upload data to Azure Data Lake.
+
+ .. seealso::
+ For more information on how to use this operator, take a look at the
guide:
+ :ref:`howto/operator:DataToADLSOperator`
+
+ :param file_system_name: Name of the file system or instance of
FileSystemProperties.
+ :param file_name: Name of the file which needs to be created in the file
system.
+ :param data: Number of threads to use. If None, uses the number of cores.
+ :param length: Number of threads to use. If None, uses the number of cores.
Review Comment:
Could we check this one as well?
--
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: commits-unsubscr...@airflow.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
