new ReceiverInputDStream(ssc_)
Parameters:
Name | Type | Description |
---|---|---|
ssc_ |
module:eclairjs/streaming.StreamingContext |
Methods
compute(validTime) → {RDD}
Parameters:
Name | Type | Description |
---|---|---|
validTime |
module:eclairjs/streaming.Time |
Returns:
- Type
- RDD
getReceiver() → {Receiver}
Gets the receiver object that will be sent to the worker nodes
to receive data. This method needs to defined by any specific implementation
of a ReceiverInputDStream.
Returns:
- Type
- Receiver
start() → {Promise.<Void>}
Returns:
A Promise that resolves to nothing.
- Type
- Promise.<Void>
stop() → {Promise.<Void>}
Returns:
A Promise that resolves to nothing.
- Type
- Promise.<Void>