BytesConverter getByteConverterForAvroDelegate(Schema schema, Properties tbl) throws SerDeException {
    String avroBytesConverterPropertyName = AvroSerdeUtils.AvroTableProperties.AVRO_SERDE_TYPE.getPropName();
    String avroBytesConverterProperty = tbl.getProperty(avroBytesConverterPropertyName,
        BytesConverterType.NONE.toString());
    BytesConverterType avroByteConverterType = BytesConverterType.fromString(avroBytesConverterProperty);
    switch (avroByteConverterType) {
    case SKIP:
      String avroSkipBytesPropertyName = AvroSerdeUtils.AvroTableProperties.AVRO_SERDE_SKIP_BYTES.getPropName();
      Integer avroSkipBytes = 0;
      try {
        avroSkipBytes = Integer.parseInt(tbl.getProperty(avroSkipBytesPropertyName));
      } catch (NumberFormatException e) {
        String message = "Value of " + avroSkipBytesPropertyName + " could not be parsed into an integer properly.";
        throw new SerDeException(message, e);
      }
      return new AvroSkipBytesConverter(schema, avroSkipBytes);
    case NONE: return new AvroBytesConverter(schema);
    default: throw new SerDeException("Value of " + avroBytesConverterPropertyName + " was invalid.");
    }
  }
Object Inspector of original row plus metadata.
kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaSerDe.java