@Override
  public RecordReader<NullWritable, KuduWritable> createRecordReader(InputSplit split,
                                                                     TaskAttemptContext context) {
    Preconditions.checkArgument(split instanceof KuduInputSplit);
    // Will be initialized via the initialize method.
    return new KuduRecordReader();
  }
A Kudu InputFormat implementation for use by Hive.
kudu-handler/src/java/org/apache/hadoop/hive/kudu/KuduInputFormat.java