public abstract class InputDStream<T> extends DStream<T>
ReceiverInputDStream
as the parent class.
param: _ssc Streaming context that will execute this input stream
Constructor and Description |
---|
InputDStream(StreamingContext _ssc,
scala.reflect.ClassTag<T> evidence$1) |
Modifier and Type | Method and Description |
---|---|
scala.collection.immutable.List<DStream<?>> |
dependencies()
List of parent DStreams on which this DStream depends on
|
int |
id()
This is a unique identifier for the input stream.
|
Duration |
slideDuration()
Time interval after which the DStream generates an RDD
|
abstract void |
start()
Method called to start receiving data.
|
abstract void |
stop()
Method called to stop receiving data.
|
cache, checkpoint, compute, context, count, countByValue, countByValueAndWindow, countByWindow, filter, flatMap, foreachRDD, foreachRDD, glom, map, mapPartitions, persist, persist, print, print, reduce, reduceByWindow, reduceByWindow, repartition, saveAsObjectFiles, saveAsTextFiles, slice, slice, toPairDStreamFunctions, transform, transform, transformWith, transformWith, union, window, window
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
$init$, initializeForcefully, initializeLogIfNecessary, initializeLogIfNecessary, initializeLogIfNecessary$default$2, initLock, isTraceEnabled, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning, org$apache$spark$internal$Logging$$log__$eq, org$apache$spark$internal$Logging$$log_, uninitialize
public InputDStream(StreamingContext _ssc, scala.reflect.ClassTag<T> evidence$1)
public scala.collection.immutable.List<DStream<?>> dependencies()
DStream
dependencies
in class DStream<T>
public int id()
public Duration slideDuration()
DStream
slideDuration
in class DStream<T>
public abstract void start()
public abstract void stop()