The TwitterInputDStream supports using filters, which is then mapped to the query filters you linked below without much manipulation on the connector side.
What filters are you using ? Are they just being ignored or are you getting specific errors ? On Thu, Oct 13, 2016 at 2:40 PM, Nidhal Selmi <[email protected]> wrote: > Greetings, > > I am trying to get a twitter stream for a research project using : > TwitterUtils.createStream(ssc, None, filters) > > But it seems that not all possible parameters are implemented : > https://dev.twitter.com/streaming/overview/request-parameters > > I checked the repo but I don't have a grasp of what is going on : > https://github.com/apache/bahir/blob/master/streaming-twitte > r/src/main/scala/org/apache/spark/streaming/twitter/ > TwitterInputDStream.scala > > How can I fix this so that I can have a stream that is bounded > geographically for example ? > > Thank you! > Nidhal. > > -- Luciano Resende http://twitter.com/lresende1975 http://lresende.blogspot.com/
