Packages

c

com.yahoo.bullet.spark

QueryReceiver

class QueryReceiver extends Receiver[PubSubMessage] with BulletSparkLogger

QueryReceiver receives queries from the PubSub and feeds it to the rest of the DAG.

Linear Supertypes
BulletSparkLogger, Receiver[PubSubMessage], Serializable, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. QueryReceiver
  2. BulletSparkLogger
  3. Receiver
  4. Serializable
  5. Serializable
  6. AnyRef
  7. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new QueryReceiver(config: BulletSparkConfig)

    Create a QueryReceiver instance that takes a configuration.

    Create a QueryReceiver instance that takes a configuration.

    config

    The com.yahoo.bullet.spark.utils.BulletSparkConfig to load settings from.

Value Members

  1. val config: BulletSparkConfig
  2. def isStarted(): Boolean
    Definition Classes
    Receiver
  3. def isStopped(): Boolean
    Definition Classes
    Receiver
  4. lazy val logger: Logger
    Definition Classes
    BulletSparkLogger
  5. def onStart(): Unit
    Definition Classes
    QueryReceiver → Receiver
  6. def onStop(): Unit
    Definition Classes
    QueryReceiver → Receiver
  7. def preferredLocation: Option[String]
    Definition Classes
    Receiver
  8. def reportError(message: String, throwable: Throwable): Unit
    Definition Classes
    Receiver
  9. def restart(message: String, error: Throwable, millisecond: Int): Unit
    Definition Classes
    Receiver
  10. def restart(message: String, error: Throwable): Unit
    Definition Classes
    Receiver
  11. def restart(message: String): Unit
    Definition Classes
    Receiver
  12. def stop(message: String, error: Throwable): Unit
    Definition Classes
    Receiver
  13. def stop(message: String): Unit
    Definition Classes
    Receiver
  14. val storageLevel: StorageLevel
    Definition Classes
    Receiver
  15. def store(bytes: ByteBuffer, metadata: Any): Unit
    Definition Classes
    Receiver
  16. def store(bytes: ByteBuffer): Unit
    Definition Classes
    Receiver
  17. def store(dataIterator: Iterator[PubSubMessage], metadata: Any): Unit
    Definition Classes
    Receiver
  18. def store(dataIterator: Iterator[PubSubMessage]): Unit
    Definition Classes
    Receiver
  19. def store(dataIterator: Iterator[PubSubMessage], metadata: Any): Unit
    Definition Classes
    Receiver
  20. def store(dataIterator: Iterator[PubSubMessage]): Unit
    Definition Classes
    Receiver
  21. def store(dataBuffer: ArrayBuffer[PubSubMessage], metadata: Any): Unit
    Definition Classes
    Receiver
  22. def store(dataBuffer: ArrayBuffer[PubSubMessage]): Unit
    Definition Classes
    Receiver
  23. def store(dataItem: PubSubMessage): Unit
    Definition Classes
    Receiver
  24. def streamId: Int
    Definition Classes
    Receiver