@Override
  public FileSinkOperator.RecordWriter getHiveRecordWriter(JobConf jc, Path finalOutPath,
                                                           Class valueClass, boolean isCompressed,
                                                           Properties tableProperties,
                                                           Progressable progress)
      throws IOException {
    return new KuduRecordWriter(createOverlayedConf(jc, tableProperties));
  }
A Kudu OutputFormatKuduPredicateHandler implementation for use by Hive.
kudu-handler/src/java/org/apache/hadoop/hive/kudu/KuduOutputFormat.java