Lee-W commented on code in PR #37103: URL: https://github.com/apache/airflow/pull/37103#discussion_r1482489951
########## 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 please 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