@Override
  public Object encode(byte[] utf8StrRecord) throws SerializationError {
    try {
      Text blob = new Text(utf8StrRecord);
      return serde.deserialize(blob);
    } catch (SerDeException e) {
      throw new SerializationError("Unable to convert byte[] record into Object", e);
    }
  }
Creates JsonSerDe

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