You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@bahir.apache.org by "Clemens Wolff (JIRA)" <ji...@apache.org> on 2017/05/04 19:23:04 UTC

[jira] [Created] (BAHIR-117) Expand filtering options for TwitterInputDStream

Clemens Wolff created BAHIR-117:
-----------------------------------

             Summary: Expand filtering options for TwitterInputDStream
                 Key: BAHIR-117
                 URL: https://issues.apache.org/jira/browse/BAHIR-117
             Project: Bahir
          Issue Type: Improvement
          Components: Spark Streaming Connectors
            Reporter: Clemens Wolff
            Priority: Minor


Currently, the TwitterInputDStream only supports filtering by keywords [1] which corresponds to the "track" option in the Twitter API [2]. The Twitter API supports many more ways to receive a filtered stream (e.g. get Tweets in a particular location [3]). It would be very useful to expose these additional filtering options in this library.

Proposal: add a new public method to TwitterUtils which follows the same interface as createStream [4] but which takes a FilterQuery [5] object as argument. In this way, we give full filtering flexibility to our users.

I'm currently working on Project Fortis, a social data analysis platform for the United Nations [6]. The extra filtering options would be very useful for my project so I'm happy to implement this and create a pull request.

[1] https://github.com/apache/bahir/blob/fd4c35fc9f7ebb57464d231cf5d66e7bc4096a1b/streaming-twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterInputDStream.scala#L44
[2] https://dev.twitter.com/streaming/overview/request-parameters#track
[3] https://dev.twitter.com/streaming/overview/request-parameters#locations
[4] https://github.com/apache/bahir/blob/fd4c35fc9f7ebb57464d231cf5d66e7bc4096a1b/streaming-twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterUtils.scala#L39
[5] http://twitter4j.org/javadoc/twitter4j/FilterQuery.html
[6] https://fortis-web.azurewebsites.net/#/site/ocha/



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)