org.apache.spark.streaming.twitter

TwitterUtils

object TwitterUtils

Source
TwitterUtils.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. TwitterUtils
  2. AnyRef
  3. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

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. def createStream(jssc: JavaStreamingContext, twitterAuth: Authorization, filters: Array[String], storageLevel: StorageLevel): JavaReceiverInputDStream[Status]

    Create a input stream that returns tweets received from Twitter.

    Create a input stream that returns tweets received from Twitter.

    jssc

    JavaStreamingContext object

    twitterAuth

    Twitter4J Authorization object

    filters

    Set of filter strings to get only those tweets that match them

    storageLevel

    Storage level to use for storing the received objects

  9. def createStream(jssc: JavaStreamingContext, twitterAuth: Authorization, filters: Array[String]): JavaReceiverInputDStream[Status]

    Create a input stream that returns tweets received from Twitter.

    Create a input stream that returns tweets received from Twitter. Storage level of the data will be the default StorageLevel.MEMORY_AND_DISK_SER_2.

    jssc

    JavaStreamingContext object

    twitterAuth

    Twitter4J Authorization

    filters

    Set of filter strings to get only those tweets that match them

  10. def createStream(jssc: JavaStreamingContext, twitterAuth: Authorization): JavaReceiverInputDStream[Status]

    Create a input stream that returns tweets received from Twitter.

    Create a input stream that returns tweets received from Twitter. Storage level of the data will be the default StorageLevel.MEMORY_AND_DISK_SER_2.

    jssc

    JavaStreamingContext object

    twitterAuth

    Twitter4J Authorization

  11. def createStream(jssc: JavaStreamingContext, filters: Array[String], storageLevel: StorageLevel): JavaReceiverInputDStream[Status]

    Create a input stream that returns tweets received from Twitter using Twitter4J's default OAuth authentication; this requires the system properties twitter4j.

    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.

    jssc

    JavaStreamingContext object

    filters

    Set of filter strings to get only those tweets that match them

    storageLevel

    Storage level to use for storing the received objects

  12. def createStream(jssc: JavaStreamingContext, filters: Array[String]): JavaReceiverInputDStream[Status]

    Create a input stream that returns tweets received from Twitter using Twitter4J's default OAuth authentication; this requires the system properties twitter4j.

    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.

    jssc

    JavaStreamingContext object

    filters

    Set of filter strings to get only those tweets that match them

  13. def createStream(jssc: JavaStreamingContext): JavaReceiverInputDStream[Status]

    Create a input stream that returns tweets received from Twitter using Twitter4J's default OAuth authentication; this requires the system properties twitter4j.

    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.

    jssc

    JavaStreamingContext object

  14. def createStream(ssc: StreamingContext, twitterAuth: Option[Authorization], filters: Seq[String] = Nil, storageLevel: StorageLevel = StorageLevel.MEMORY_AND_DISK_SER_2): ReceiverInputDStream[Status]

    Create a input stream that returns tweets received from Twitter.

    Create a input stream that returns tweets received from Twitter.

    ssc

    StreamingContext object

    twitterAuth

    Twitter4J authentication, or None to use Twitter4J's default OAuth authorization; this uses the system properties twitter4j.oauth.consumerKey, twitter4j.oauth.consumerSecret, twitter4j.oauth.accessToken and twitter4j.oauth.accessTokenSecret

    filters

    Set of filter strings to get only those tweets that match them

    storageLevel

    Storage level to use for storing the received objects

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

    Definition Classes
    AnyRef
  16. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  17. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  18. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  19. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  20. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  21. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  22. final def notify(): Unit

    Definition Classes
    AnyRef
  23. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  24. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  25. def toString(): String

    Definition Classes
    AnyRef → Any
  26. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  27. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  28. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from AnyRef

Inherited from Any

Ungrouped