org.apache.spark.streaming

kafka

package kafka

Kafka receiver for spark streaming,

Source
package.scala
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

    Represents the host and port info for a Kafka broker.

  2. trait HasOffsetRanges extends AnyRef

    Represents any object that has a collection of OffsetRanges.

  3. final class OffsetRange extends Serializable

    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

    Companion object the provides methods to create instances of OffsetRange.

Inherited from AnyRef

Inherited from Any

Ungrouped