class DSLReceiver extends Receiver[AnyRef] with BulletSparkLogger
Create a DSLReceiver from the given configuration.
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- DSLReceiver
- BulletSparkLogger
- Receiver
- Serializable
- Serializable
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Instance Constructors
-
new
DSLReceiver(config: BulletDSLConfig)
- config
The
BulletDSLConfig
to load settings from.
Value Members
- val config: BulletDSLConfig
- var connector: BulletConnector
-
def
isStarted(): Boolean
- Definition Classes
- Receiver
-
def
isStopped(): Boolean
- Definition Classes
- Receiver
-
lazy val
logger: Logger
- Definition Classes
- BulletSparkLogger
-
def
onStart(): Unit
- Definition Classes
- DSLReceiver → Receiver
-
def
onStop(): Unit
- Definition Classes
- DSLReceiver → Receiver
-
def
preferredLocation: Option[String]
- Definition Classes
- Receiver
-
def
reportError(message: String, throwable: Throwable): Unit
- Definition Classes
- Receiver
-
def
restart(message: String, error: Throwable, millisecond: Int): Unit
- Definition Classes
- Receiver
-
def
restart(message: String, error: Throwable): Unit
- Definition Classes
- Receiver
-
def
restart(message: String): Unit
- Definition Classes
- Receiver
-
def
stop(message: String, error: Throwable): Unit
- Definition Classes
- Receiver
-
def
stop(message: String): Unit
- Definition Classes
- Receiver
-
val
storageLevel: StorageLevel
- Definition Classes
- Receiver
-
def
store(bytes: ByteBuffer, metadata: Any): Unit
- Definition Classes
- Receiver
-
def
store(bytes: ByteBuffer): Unit
- Definition Classes
- Receiver
-
def
store(dataIterator: Iterator[AnyRef], metadata: Any): Unit
- Definition Classes
- Receiver
-
def
store(dataIterator: Iterator[AnyRef]): Unit
- Definition Classes
- Receiver
-
def
store(dataIterator: Iterator[AnyRef], metadata: Any): Unit
- Definition Classes
- Receiver
-
def
store(dataIterator: Iterator[AnyRef]): Unit
- Definition Classes
- Receiver
-
def
store(dataBuffer: ArrayBuffer[AnyRef], metadata: Any): Unit
- Definition Classes
- Receiver
-
def
store(dataBuffer: ArrayBuffer[AnyRef]): Unit
- Definition Classes
- Receiver
-
def
store(dataItem: AnyRef): Unit
- Definition Classes
- Receiver
-
def
streamId: Int
- Definition Classes
- Receiver