@Override
  public org.apache.hadoop.mapred.RecordReader<NullWritable, KuduWritable> getRecordReader(
      org.apache.hadoop.mapred.InputSplit split, JobConf conf, Reporter reporter)
      throws IOException {
    Preconditions.checkArgument(split instanceof KuduInputSplit);
    KuduRecordReader recordReader = new KuduRecordReader();
    recordReader.initialize((KuduInputSplit) split, conf);
    return recordReader;
  }
A Kudu InputFormat implementation for use by Hive.
kudu-handler/src/java/org/apache/hadoop/hive/kudu/KuduInputFormat.java