@Override
  public JsonSerDe createSerde() throws SerializationError {
    try {
      Properties tableProps = table.getMetadata();
      tableProps.setProperty(serdeConstants.LIST_COLUMNS, Joiner.on(",").join(inputColumns));
      tableProps.setProperty(serdeConstants.LIST_COLUMN_TYPES, Joiner.on(":").join(inputTypes));
      JsonSerDe serde = new JsonSerDe();
      serde.initialize(conf, tableProps, null);
      this.serde = serde;
      return serde;
    } catch (SerDeException e) {
      throw new SerializationError("Error initializing serde " + JsonSerDe.class.getName(), e);
    }
  }
Creates JsonSerDe

@throws SerializationError if serde could not be initialized
streaming/src/java/org/apache/hive/streaming/StrictJsonWriter.java