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. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  6. val config: BulletSparkConfig
  7. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  8. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  9. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  10. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  11. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  12. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  13. def isStarted(): Boolean
    Definition Classes
    Receiver
  14. def isStopped(): Boolean
    Definition Classes
    Receiver
  15. lazy val logger: Logger
    Definition Classes
    BulletSparkLogger
  16. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  17. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  18. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  19. def onStart(): Unit
    Definition Classes
    QueryReceiver → Receiver
  20. def onStop(): Unit
    Definition Classes
    QueryReceiver → Receiver
  21. def preferredLocation: Option[String]
    Definition Classes
    Receiver
  22. def reportError(message: String, throwable: Throwable): Unit
    Definition Classes
    Receiver
  23. def restart(message: String, error: Throwable, millisecond: Int): Unit
    Definition Classes
    Receiver
  24. def restart(message: String, error: Throwable): Unit
    Definition Classes
    Receiver
  25. def restart(message: String): Unit
    Definition Classes
    Receiver
  26. def stop(message: String, error: Throwable): Unit
    Definition Classes
    Receiver
  27. def stop(message: String): Unit
    Definition Classes
    Receiver
  28. val storageLevel: StorageLevel
    Definition Classes
    Receiver
  29. def store(bytes: ByteBuffer, metadata: Any): Unit
    Definition Classes
    Receiver
  30. def store(bytes: ByteBuffer): Unit
    Definition Classes
    Receiver
  31. def store(dataIterator: Iterator[PubSubMessage], metadata: Any): Unit
    Definition Classes
    Receiver
  32. def store(dataIterator: Iterator[PubSubMessage]): Unit
    Definition Classes
    Receiver
  33. def store(dataIterator: Iterator[PubSubMessage], metadata: Any): Unit
    Definition Classes
    Receiver
  34. def store(dataIterator: Iterator[PubSubMessage]): Unit
    Definition Classes
    Receiver
  35. def store(dataBuffer: ArrayBuffer[PubSubMessage], metadata: Any): Unit
    Definition Classes
    Receiver
  36. def store(dataBuffer: ArrayBuffer[PubSubMessage]): Unit
    Definition Classes
    Receiver
  37. def store(dataItem: PubSubMessage): Unit
    Definition Classes
    Receiver
  38. def streamId: Int
    Definition Classes
    Receiver
  39. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  40. def toString(): String
    Definition Classes
    AnyRef → Any
  41. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  42. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  43. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )

Inherited from BulletSparkLogger

Inherited from Receiver[PubSubMessage]

Inherited from Serializable

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped