У меня есть требование, при котором я должен передать выходные данные преобразования выбора из одного потока данных (потока данных) в другой напрямую.
Пример:
У меня есть поток данных с преобразованием SELECT в качестве заключительного шага.
У меня есть другой поток данных, который должен принять вышеуказанный вывод преобразования SELECT в качестве ввода.
В настоящее время я сохраняю вывод первого потока данных в таблицу и получаю данные из таблицы во втором потоке данных, выполнение которого занимает много времени. Я хочу избежать хранения в таблице.
Спасибо, Картик
Потоки данных требуют, чтобы ваша логика c заканчивалась Sink, когда вы выполняете их из конвейера, поэтому вы должны сохранить свой вывод где-то в Azure. Следующая конвейерная операция может считываться из этого выходного набора данных.