Packages

c

com.yahoo.bullet.spark

DSLReceiver

class DSLReceiver extends Receiver[AnyRef] with BulletSparkLogger

Create a DSLReceiver from the given configuration.

Linear Supertypes
BulletSparkLogger, Receiver[AnyRef], Serializable, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. DSLReceiver
  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 DSLReceiver(config: BulletDSLConfig)

    config

    The BulletDSLConfig to load settings from.

Value Members

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