Структура Spark Потоки foreach Writer в несколько приемников - PullRequest
0 голосов
/ 03 октября 2019

Привет! Я попытался записать данные набора данных в несколько приемников, используя средство записи forEach. Могу ли я передать несколько приемников foreach в потоковом запросе, как я упоминал ниже? если предположить, что у меня два приемника в одном запросе, произойдет любая проблема с производительностью ??

StreamingQuery query=df1
  .writeStream()
  .foreach(sink1)
  .foreach(sink2)
  .start();
...