Hierarchy For Package org.apache.spark.streaming.kafka

Package Hierarchies:

• All Packages

Class Hierarchy

• Object
  • scala.runtime.AbstractFunction3<T1,T2,T3,R> (implements scala.Function3<T1,T2,T3,R>)
    • org.apache.spark.streaming.kafka.KafkaCluster.LeaderOffset$ (implements scala.Serializable)
  • org.apache.spark.streaming.kafka.Broker (implements scala.Serializable)
  • org.apache.spark.streaming.dstream.DStream<T> (implements org.apache.spark.Logging, scala.Serializable)
    • org.apache.spark.streaming.dstream.InputDStream<T>
      • org.apache.spark.streaming.kafka.DirectKafkaInputDStream<K,V,U,T,R> (implements org.apache.spark.Logging)
      • org.apache.spark.streaming.dstream.ReceiverInputDStream<T>
        • org.apache.spark.streaming.kafka.KafkaInputDStream<K,V,U,T> (implements org.apache.spark.Logging)
  • org.apache.spark.streaming.dstream.DStreamCheckpointData<T> (implements org.apache.spark.Logging, scala.Serializable)
    • org.apache.spark.streaming.kafka.DirectKafkaInputDStream.DirectKafkaInputDStreamCheckpointData
  • org.apache.spark.streaming.kafka.KafkaCluster (implements scala.Serializable)
  • org.apache.spark.streaming.kafka.KafkaCluster.LeaderOffset (implements scala.Product, scala.Serializable)
  • org.apache.spark.streaming.kafka.KafkaCluster.SimpleConsumerConfig$
  • org.apache.spark.streaming.kafka.KafkaRDDPartition (implements org.apache.spark.Partition)
  • org.apache.spark.streaming.kafka.KafkaUtils
  • org.apache.spark.streaming.kafka.KafkaUtilsPythonHelper
  • org.apache.spark.streaming.kafka.OffsetRange (implements scala.Serializable)
  • org.apache.spark.rdd.RDD<T> (implements org.apache.spark.Logging, scala.Serializable)
    • org.apache.spark.streaming.kafka.KafkaRDD<K,V,U,T,R> (implements org.apache.spark.streaming.kafka.HasOffsetRanges, org.apache.spark.Logging)
  • org.apache.spark.streaming.receiver.Receiver<T> (implements scala.Serializable)
    • org.apache.spark.streaming.kafka.KafkaReceiver<K,V,U,T> (implements org.apache.spark.Logging)
    • org.apache.spark.streaming.kafka.ReliableKafkaReceiver<K,V,U,T> (implements org.apache.spark.Logging)
  • kafka.utils.ZKConfig
    • kafka.consumer.ConsumerConfig
      • org.apache.spark.streaming.kafka.KafkaCluster.SimpleConsumerConfig

Interface Hierarchy

• org.apache.spark.streaming.kafka.HasOffsetRanges