Addieren des Sprachfilters zum Twittern von popularhashtags - scala
Ich bin neu bei Spark und Scala. Ich habe die beliebten Hashtags von Spark-Streaming-Job-Twitter verwendet.
Ich habe einen Filter für einige Wörter hinzugefügt und konnte Tweets herausfiltern:
val filter = Array("spark", "Big Data")
val stream = TwitterUtils.createStream(ssc, None, filter)
Ich möchte auch einen Sprachfilter hinzufügen, damit nur englische Tweets gestreamt werden. Twitter4j hatTrack()
undLocations
. Hat es einen Sprachfilter? Wenn ja, wie funktioniert das in Scala?