|
|||||||||
PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES |
See:
Description
Interface Summary | |
---|---|
HasOffsetRanges | :: Experimental ::
Represents any object that has a collection of OffsetRange s. |
Class Summary | |
---|---|
Broker | :: Experimental :: Represent the host and port info for a Kafka broker. |
KafkaTestUtils | This is a helper class for Kafka test suites. |
KafkaUtils | |
KafkaUtilsPythonHelper | This is a helper class that wraps the KafkaUtils.createStream() into more Python-friendly class and function so that it can be easily instantiated and called from Python's KafkaUtils (see SPARK-6027). |
OffsetRange | :: Experimental :: Represents a range of offsets from a single Kafka TopicAndPartition. |
Kafka receiver for spark streaming.
|
|||||||||
PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES |