@Override
  public void write(final long writeId, final InputStream inputStream) throws StreamingException {
    try (Scanner scanner = new Scanner(inputStream).useDelimiter(lineDelimiter)) {
      while (scanner.hasNext()) {
        write(writeId, scanner.next().getBytes());
      }
    }
  }
Encode a record as an Object that Hive can read with the ObjectInspector associated with the
serde returned by {@link #createSerde}.  This is public so that test frameworks can use it.

@param record record to be deserialized
@return deserialized record as an Object
@throws SerializationError - any error during serialization or deserialization of record
streaming/src/java/org/apache/hive/streaming/AbstractRecordWriter.java