Hi I wrote a little prototype that created a ³public stream² now I want to convert it to read tweets for a large number of explicit users.
I to create a ³user stream² or a ³site stream". According to the twitter developer doc I should be able to set the ³follows² parameter to a list of users I am interested in https://dev.twitter.com/streaming/overview/request-parameters#follow follow A comma-separated list of user IDs, indicating the users whose Tweets should be delivered on the stream. I am not sure how to do this? I found the doc for createStream. I am guessing I need to set filters? Can anyone provide a example? Kind regards Andy http://spark.apache.org/docs/latest/api/java/index.html createStream public static JavaReceiverInputDStream <http://spark.apache.org/docs/latest/api/java/org/apache/spark/streaming/api /java/JavaReceiverInputDStream.html> <twitter4j.Status> createStream(JavaStreamingContext <http://spark.apache.org/docs/latest/api/java/org/apache/spark/streaming/api /java/JavaStreamingContext.html> jssc, java.lang.String[] filters) Create a input stream that returns tweets received from Twitter using Twitter4J's default OAuth authentication; this requires the system properties twitter4j.oauth.consumerKey, twitter4j.oauth.consumerSecret, twitter4j.oauth.accessToken and twitter4j.oauth.accessTokenSecret. Storage level of the data will be the default StorageLevel.MEMORY_AND_DISK_SER_2. Parameters:jssc - JavaStreamingContext objectfilters - Set of filter strings to get only those tweets that match themReturns:(undocumented)
