T - Class type of the object of this streampublic abstract class ReceiverInputDStream<T> extends InputDStream<T>
InputDStream
that has to start a receiver on worker nodes to receive external data.
Specific implementations of ReceiverInputDStream must
define getReceiver function that gets the receiver object of type
Receiver that will be sent
to the workers to receive data.
param: _ssc Streaming context that will execute this input stream| Constructor and Description |
|---|
ReceiverInputDStream(StreamingContext _ssc,
scala.reflect.ClassTag<T> evidence$1) |
| Modifier and Type | Method and Description |
|---|---|
scala.Option<RDD<T>> |
compute(Time validTime)
Method that generates an RDD for the given time
|
abstract Receiver<T> |
getReceiver()
Gets the receiver object that will be sent to the worker nodes
to receive data.
|
void |
start()
Method called to start receiving data.
|
void |
stop()
Method called to stop receiving data.
|
dependencies, id, slideDurationcache, checkpoint, 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, windowequals, 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_, uninitializepublic ReceiverInputDStream(StreamingContext _ssc, scala.reflect.ClassTag<T> evidence$1)
public scala.Option<RDD<T>> compute(Time validTime)
DStreampublic abstract Receiver<T> getReceiver()
public void start()
InputDStreamstart in class InputDStream<T>public void stop()
InputDStreamstop in class InputDStream<T>