ElasticsearchPrinter

Value Members

1. final def !=(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef

2. final def !=(arg0: Any): Boolean

   Definition Classes

   Any

3. final def ##(): Int

   Definition Classes

   AnyRef → Any

4. final def ==(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef

5. final def ==(arg0: Any): Boolean

   Definition Classes

   Any

6. final def asInstanceOf[T0]: T0

   Definition Classes

   Any

7. def clone(): AnyRef

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

8. final def eq(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef

9. def equals(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

10. def finalize(): Unit

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

11. final def getClass(): Class[_]

    Definition Classes

    AnyRef → Any

12. def handleException(exception: Throwable): Unit

    Gets called when an exception occurred during providing the Tweets.

    Gets called when an exception occurred during providing the Tweets. This will be a fatal exception, and tweets will not continue to flow after this exception occurred.

    exception

    the fatal exception

    Definition Classes

    PrintText → TweetConsumer

13. def hashCode(): Int

    Definition Classes

    AnyRef → Any

14. def host: String

    The hostname of the Elasticsearch server.

    The hostname of the Elasticsearch server.

    Definition Classes

    ElasticsearchPrinter → ElasticsearchScanTweets

15. def index: String

    The index that contains the tweets.

    The index that contains the tweets.

    Definition Classes

    ElasticsearchPrinter → ElasticsearchScanTweets

16. final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

17. final def iterable: Iterable[String]

    Uses the Elasticsearch Scan/Scroll API to obtain Tweets

    Uses the Elasticsearch Scan/Scroll API to obtain Tweets

    returns

    an Iterable of Strings, where every String is the JSON representation on a bbuzz.Tweet

    Definition Classes

    ElasticsearchScanTweets → FromStringIterable

18. final def main(args: Array[String]): Unit

    Definition Classes

    TweetStreaming

19. final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

20. final def notify(): Unit

    Definition Classes

    AnyRef

21. final def notifyAll(): Unit

    Definition Classes

    AnyRef

22. final def onCompleted(): Unit

    Definition Classes

    TweetConsumer → Observer

23. final def onError(error: Throwable): Unit

    Definition Classes

    TweetConsumer → Observer

24. final def onNext(value: Tweet): Unit

    Definition Classes

    TweetConsumer → Observer

25. def onTweet(tweet: Tweet): Unit

    Gets called for every tweet that is pulled from the bbuzz.TweetProvider.

    Gets called for every tweet that is pulled from the bbuzz.TweetProvider. This method should not block and complete quickly.

    tweet

    a new bbuzz.Tweet

    Definition Classes

    PrintText → TweetConsumer

26. def port: Int

    The port of the HTTP endpoint of the Elasticsearch server.

    The port of the HTTP endpoint of the Elasticsearch server.

    Definition Classes

    ElasticsearchPrinter → ElasticsearchScanTweets

27. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes

    AnyRef

28. def toString(): String

    Definition Classes

    AnyRef → Any

29. final def tweets: TweetObservable

    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

    returns

    an Observable of Tweets

    Definition Classes

    FromStringIterable → TweetProvider

30. final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

31. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

32. final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )