Как подключить потоковые данные Spark к панели мониторинга Power BI для аналитики в реальном времени? - PullRequest
0 голосов
/ 11 июня 2019

Как подключить выходные слова в Power BI Dashboard? Это мой потоковый код Spark:

val ssc = new StreamingContext(sc, Seconds(10))
val lines = ssc.textFileStream("/tmp/sanal/dcsStreaming/")
val words = lines.flatMap(_.split(" "))
val pairs = words.map((_, 1))
val wordCounts = pairs.reduceByKey(_ + _)
Wordcounts.print()

ssc.start()
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...