public class KafkaInputDStream<K,V,U extends kafka.serializer.Decoder<?>,T extends kafka.serializer.Decoder<?>> extends ReceiverInputDStream<scala.Tuple2<K,V>> implements Logging
Constructor and Description |
---|
KafkaInputDStream(StreamingContext ssc_,
scala.collection.Map<String,String> kafkaParams,
scala.collection.Map<String,Object> topics,
boolean useReliableReceiver,
StorageLevel storageLevel,
scala.reflect.ClassTag<K> evidence$1,
scala.reflect.ClassTag<V> evidence$2,
scala.reflect.ClassTag<U> evidence$3,
scala.reflect.ClassTag<T> evidence$4) |
Modifier and Type | Method and Description |
---|---|
Receiver<scala.Tuple2<K,V>> |
getReceiver()
Gets the receiver object that will be sent to the worker nodes
to receive data.
|
clearMetadata, compute, id, start, stop
dependencies, isTimeValid, lastValidTime, slideDuration
cache, checkpoint, checkpointData, checkpointDuration, clearCheckpointData, 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 KafkaInputDStream(StreamingContext ssc_, scala.collection.Map<String,String> kafkaParams, scala.collection.Map<String,Object> topics, boolean useReliableReceiver, StorageLevel storageLevel, scala.reflect.ClassTag<K> evidence$1, scala.reflect.ClassTag<V> evidence$2, scala.reflect.ClassTag<U> evidence$3, scala.reflect.ClassTag<T> evidence$4)
public Receiver<scala.Tuple2<K,V>> getReceiver()
ReceiverInputDStream
getReceiver
in class ReceiverInputDStream<scala.Tuple2<K,V>>