The hostname of the Elasticsearch server.
The index that contains the tweets.
The port of the HTTP endpoint of the Elasticsearch server.
Uses the Elasticsearch Scan/Scroll API to obtain Tweets
Uses the Elasticsearch Scan/Scroll API to obtain Tweets
an Iterable of Strings, where every String is the JSON representation on a bbuzz.Tweet
Tweets are provided as an rx.lang.scala.Observable.
Tweets are provided as an rx.lang.scala.Observable.
You can implement this in any way you like, though you might want to have a look at the companions object's helper traits.
This Observable
will be consumed by a bbuzz.TweetConsumer
an Observable
of Tweets
Provides tweets by scanning an Elasticsearch index.
All documents contained in a given index are expected to be valid tweets. This uses the HTTP connection, not the internal transport.