@Override public Object deserialize(Writable blob) throws SerDeException {
    Object[] rowBoat = new Object[columnNames.size()];
    deserializeKWritable((KafkaWritable) blob, rowBoat);
    return rowBoat;
  }
Object Inspector of original row plus metadata.
kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaSerDe.java