Hierarchy For Package com.linkedin.venice.hadoop.input.kafka

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • com.linkedin.venice.hadoop.task.datawriter.AbstractDataWriterTask
    • com.linkedin.venice.hadoop.task.datawriter.AbstractInputRecordProcessor<INPUT_KEY,INPUT_VALUE> (implements java.io.Closeable)
      • com.linkedin.venice.hadoop.mapreduce.datawriter.map.AbstractVeniceMapper<INPUT_KEY,INPUT_VALUE> (implements org.apache.hadoop.mapred.Mapper<K1,V1,K2,V2>)
        • com.linkedin.venice.hadoop.input.kafka.VeniceKafkaInputMapper
    • com.linkedin.venice.hadoop.task.datawriter.AbstractPartitionWriter (implements java.io.Closeable)
      • com.linkedin.venice.hadoop.mapreduce.datawriter.reduce.VeniceReducer (implements org.apache.hadoop.mapred.Reducer<K2,V2,K3,V3>)
        • com.linkedin.venice.hadoop.input.kafka.VeniceKafkaInputReducer
    • com.linkedin.venice.hadoop.input.kafka.KafkaInputFormatCombiner (implements org.apache.hadoop.mapred.JobConfigurable, org.apache.hadoop.mapred.Reducer<K2,V2,K3,V3>)
  • com.linkedin.venice.hadoop.input.kafka.KafkaInputDictTrainer
  • com.linkedin.venice.hadoop.input.kafka.KafkaInputDictTrainer.Param
  • com.linkedin.venice.hadoop.input.kafka.KafkaInputDictTrainer.ParamBuilder
  • com.linkedin.venice.hadoop.input.kafka.KafkaInputFormat (implements org.apache.hadoop.mapred.InputFormat<K,V>)
  • com.linkedin.venice.hadoop.input.kafka.KafkaInputKeyComparator (implements org.apache.hadoop.io.RawComparator<T>, java.io.Serializable)
    • com.linkedin.venice.hadoop.input.kafka.KafkaInputValueGroupingComparator
  • com.linkedin.venice.hadoop.input.kafka.KafkaInputRecordReader (implements java.lang.AutoCloseable, org.apache.hadoop.mapred.RecordReader<K,V>)
  • com.linkedin.venice.hadoop.input.kafka.KafkaInputSplit (implements org.apache.hadoop.mapred.InputSplit)
  • com.linkedin.venice.hadoop.input.kafka.KafkaInputUtils
  • com.linkedin.venice.hadoop.mapreduce.datawriter.partition.VeniceMRPartitioner (implements org.apache.hadoop.mapred.Partitioner<K2,V2>)
    • com.linkedin.venice.hadoop.input.kafka.KafkaInputMRPartitioner