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. 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: BulletDSLConfig
  7. var connector: BulletConnector
  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
    Annotations
    @native()
  12. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  13. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  14. def isStarted(): Boolean
    Definition Classes
    Receiver
  15. def isStopped(): Boolean
    Definition Classes
    Receiver
  16. lazy val logger: Logger
    Definition Classes
    BulletSparkLogger
  17. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  18. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  19. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  20. def onStart(): Unit
    Definition Classes
    DSLReceiver → Receiver
  21. def onStop(): Unit
    Definition Classes
    DSLReceiver → Receiver
  22. def preferredLocation: Option[String]
    Definition Classes
    Receiver
  23. def reportError(message: String, throwable: Throwable): Unit
    Definition Classes
    Receiver
  24. def restart(message: String, error: Throwable, millisecond: Int): Unit
    Definition Classes
    Receiver
  25. def restart(message: String, error: Throwable): Unit
    Definition Classes
    Receiver
  26. def restart(message: String): Unit
    Definition Classes
    Receiver
  27. def stop(message: String, error: Throwable): Unit
    Definition Classes
    Receiver
  28. def stop(message: String): Unit
    Definition Classes
    Receiver
  29. val storageLevel: StorageLevel
    Definition Classes
    Receiver
  30. def store(bytes: ByteBuffer, metadata: Any): Unit
    Definition Classes
    Receiver
  31. def store(bytes: ByteBuffer): Unit
    Definition Classes
    Receiver
  32. def store(dataIterator: Iterator[AnyRef], metadata: Any): Unit
    Definition Classes
    Receiver
  33. def store(dataIterator: Iterator[AnyRef]): Unit
    Definition Classes
    Receiver
  34. def store(dataIterator: Iterator[AnyRef], metadata: Any): Unit
    Definition Classes
    Receiver
  35. def store(dataIterator: Iterator[AnyRef]): Unit
    Definition Classes
    Receiver
  36. def store(dataBuffer: ArrayBuffer[AnyRef], metadata: Any): Unit
    Definition Classes
    Receiver
  37. def store(dataBuffer: ArrayBuffer[AnyRef]): Unit
    Definition Classes
    Receiver
  38. def store(dataItem: AnyRef): Unit
    Definition Classes
    Receiver
  39. def streamId: Int
    Definition Classes
    Receiver
  40. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  41. def toString(): String
    Definition Classes
    AnyRef → Any
  42. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  43. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  44. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )

Inherited from BulletSparkLogger

Inherited from Receiver[AnyRef]

Inherited from Serializable

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped