@Override
    public void write(Writable row) throws IOException {
      Preconditions.checkArgument(row instanceof KuduWritable);
      Operation op = table.newUpsert();
      ((KuduWritable) row).populateRow(op.getRow());
      session.apply(op);
    }
A Kudu OutputFormatKuduPredicateHandler implementation for use by Hive.
kudu-handler/src/java/org/apache/hadoop/hive/kudu/KuduOutputFormat.java