Class: InputDStream

InputDStream

new InputDStream(ssc_) → {Promise.<Void>}

Parameters:
Name Type Description
ssc_ module:eclairjs/streaming.StreamingContext
Source:
Returns:
A Promise that resolves to nothing.
Type
Promise.<Void>

Methods

dependencies() → {Array.<DStream>}

Source:
Returns:
Type
Array.<DStream>

slideDuration() → {Duration}

Source:
Returns:
Type
Duration

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>