I think it's a twitter4j issue although I am not sure. I am not getting any errors but the API allows for more types of filters, while only the "track"one is implemented, which takes a list of strings as input. https://dev.twitter.com/streaming/overview/request-parameters
notice this piece of code from here https://github.com/apache/bahir/blob/master/streaming-twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterInputDStream.scala val query = new FilterQuery if (filters.size > 0) { query.track(filters.mkString(",")) newTwitterStream.filter(query) } else { newTwitterStream.sample() } On Thu, Oct 13, 2016 at 3:52 PM, Luciano Resende <luckbr1...@gmail.com> wrote: > 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 <nse...@asu.edu> 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/TwitterI >> nputDStream.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/ >
