Как транслировать API Twitter в Spark Scala

Как читать твиты Твиттера, используя scala, используя потоковую трансляцию. Я не могу найти какие-либо искровые разъемы для Twitter.

Источник

1 ответ

Я использовал spark-streaming-twitter разъем твиттера для чтения твитов. Чтобы установить это на DSX, я использовал pixiedust,

искровым потокового твиттер

import pixiedust

pixiedust.installPackage("org.apache.bahir:spark-streaming-twitter_2.11:2.0.1")

import org.apache.spark.streaming.twitter._

TwitterUtils.createStream(ssc, None)
Источник
Другие вопросы по тегам