org.apache.spark.streaming

kafka

package kafka

Kafka receiver for spark streaming,

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. kafka
  2. AnyRef
  3. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Type Members

  1. final class Broker extends Serializable

    :: Experimental :: Represent the host and port info for a Kafka broker.

  2. trait HasOffsetRanges extends AnyRef

    :: Experimental :: Represents any object that has a collection of OffsetRanges.

  3. final class OffsetRange extends Serializable

    :: Experimental :: Represents a range of offsets from a single Kafka TopicAndPartition.

Value Members

  1. object Broker extends Serializable

    :: Experimental :: Companion object that provides methods to create instances of Broker.

  2. object KafkaUtils

  3. object OffsetRange extends Serializable

    :: Experimental :: Companion object the provides methods to create instances of OffsetRange.

Inherited from AnyRef

Inherited from Any

Ungrouped