Я рекомендую использовать функцию сопоставления потока данных ADF, которая построена на Spark в облаке.
1. Создайте новый поток данных
2. Добавьте исходный файл
3. Добавьте папку Sink, указав разделение
4. Сохраните поток данных
5. Затем добавьте действие Execute Data Flow и выберите новый поток данных разделения файлов