добавление языкового фильтра в твиттер популярные хэштеги - scala
Я новичок в Spark и Scala. Я запустил популярные хэш-теги Spark для потоковой передачи заданий.
Я добавил фильтр для некоторых слов и смог отфильтровать твиты:
val filter = Array("spark", "Big Data")
val stream = TwitterUtils.createStream(ssc, None, filter)
Также я хочу добавить языковой фильтр, чтобы транслировались только английские твиты. Twitter4j имеетTrack()
а такжеLocations
, Есть ли у него языковой фильтр? Если да, то как это работает в Scala?