2016-04-26 2 views
-1

Как выполнить потоковую передачу данных Twitter через Apache Spark Streaming?Как выполнить потоковую передачу данных Twitter через Apache Spark Streaming?

Раньше я извлекал данные twitter через флюс и хранился в HDFS, где я настраивал учетные данные для входа в твиттер в conf.txt.

Но теперь застрял в получении данных twitter через Apache Spark Streaming.

Проблема с размещением щебет учетные данные .. Пожалуйста, помогите мне ..

+0

, что вы делали до сих пор, и какие ошибки вы получаете? – maasg

+0

Это мой код: –

+0

if (args.length <5) \t { \t String consumerKey = args [0]; \t String consumerSecret = args [1]; \t Строка accessToken = args [2]; \t String accessTokenSecret = args [3]; –

ответ

0

Почему бы вам не использовать sc.setLocalProperties()? создать

val ssc = new StreamingContext("local[10]", "test", Duration(3000)) 
val sc = ssc.sparkContext 

и

sc.setLocalProperties() 
+0

Как передавать данные твиттера в эластичный поиск? код в java plz .. –

Смежные вопросы