public class PluggableInputDStream<T> extends ReceiverInputDStream<T>
Constructor and Description |
---|
PluggableInputDStream(StreamingContext ssc_,
Receiver<T> receiver,
scala.reflect.ClassTag<T> evidence$1) |
Modifier and Type | Method and Description |
---|---|
Receiver<T> |
getReceiver()
Gets the receiver object that will be sent to the worker nodes
to receive data.
|
compute, id, start, stop
dependencies, isTimeValid, lastValidTime, slideDuration
cache, checkpoint, checkpointData, checkpointDuration, clearCheckpointData, clearMetadata, context, count, countByValue, countByValueAndWindow, countByWindow, creationSite, filter, flatMap, foreach, foreach, foreachRDD, foreachRDD, generatedRDDs, generateJob, getCreationSite, getOrCompute, glom, graph, initialize, isInitialized, map, mapPartitions, mustCheckpoint, parentRememberDuration, persist, persist, print, reduce, reduceByWindow, reduceByWindow, register, remember, rememberDuration, repartition, restoreCheckpointData, saveAsObjectFiles, saveAsTextFiles, setContext, setGraph, slice, slice, ssc, storageLevel, transform, transform, transformWith, transformWith, union, updateCheckpointData, validate, window, window, zeroTime
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning
public PluggableInputDStream(StreamingContext ssc_, Receiver<T> receiver, scala.reflect.ClassTag<T> evidence$1)
public Receiver<T> getReceiver()
ReceiverInputDStream
getReceiver
in class ReceiverInputDStream<T>