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.
|
compute, id, start, stopdependencies, isTimeValid, lastValidTime, slideDurationcache, 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, zeroTimeequals, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitinitializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarningpublic 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()
ReceiverInputDStreamgetReceiver in class ReceiverInputDStream<scala.Tuple2<K,V>>