Home
last modified time | relevance | path

Searched refs:ReliableKafkaReceiver (Results 1 – 2 of 2) sorted by relevance

/dports/devel/spark/spark-2.1.1/external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/
H A DKafkaInputDStream.scala62 new ReliableKafkaReceiver[K, V, U, T](kafkaParams, topics, storageLevel)
H A DReliableKafkaReceiver.scala52 class ReliableKafkaReceiver[ class