public class MQTTInputDStream extends ReceiverInputDStream<String>
Constructor and Description |
---|
MQTTInputDStream(StreamingContext ssc_,
String brokerUrl,
String topic,
StorageLevel storageLevel) |
Modifier and Type | Method and Description |
---|---|
Receiver<String> |
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, print, reduce, reduceByWindow, reduceByWindow, register, remember, rememberDuration, repartition, restoreCheckpointData, saveAsObjectFiles, saveAsTextFiles, setContext, setGraph, slice, slice, ssc, storageLevel, toPairDStreamFunctions, 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 MQTTInputDStream(StreamingContext ssc_, String brokerUrl, String topic, StorageLevel storageLevel)
public Receiver<String> getReceiver()
ReceiverInputDStream
getReceiver
in class ReceiverInputDStream<String>