This project has retired. For details please refer to its
        
        Attic page.
      
Class Hierarchy
- java.lang.Object
- org.apache.hadoop.mapreduce.InputFormat<K,V>
- org.apache.crunch.kafka.inputformat.KafkaInputFormat (implements org.apache.hadoop.conf.Configurable)
 
- org.apache.hadoop.mapreduce.InputSplit
- org.apache.crunch.kafka.inputformat.KafkaInputSplit (implements org.apache.hadoop.io.Writable)
 
- org.apache.hadoop.mapreduce.RecordReader<KEYIN,VALUEIN> (implements java.io.Closeable)
 
 
Copyright © 2017 The Apache Software Foundation. All rights reserved.