Class: ReceiverInputDStream

ReceiverInputDStream

new ReceiverInputDStream(ssc_)

Parameters:
Name Type Description
ssc_ module:eclairjs/streaming.StreamingContext
Source:

Methods

compute(validTime) → {RDD}

Parameters:
Name Type Description
validTime module:eclairjs/streaming.Time
Source:
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.
Source:
Returns:
Type
Receiver

start() → {Promise.<Void>}

Source:
Returns:
A Promise that resolves to nothing.
Type
Promise.<Void>

stop() → {Promise.<Void>}

Source:
Returns:
A Promise that resolves to nothing.
Type
Promise.<Void>