code: @Override
    public Iterable<FileAwareInputStream> convertRecord(String outputSchema, FileAwareInputStream fileAwareInputStream,
        WorkUnitState workUnit) throws DataConversionException {
  
      modifyExtensionAtDestination(fileAwareInputStream.getFile());
      try {
        InputStream newInputStream = inputStreamTransformation().apply(fileAwareInputStream.getInputStream());
        return new SingleRecordIterable<>(fileAwareInputStream.toBuilder().inputStream(newInputStream).build());
      } catch (RuntimeException re) {
        throw new DataConversionException(re);
      }
    }
docs: Applies the transformation in {@link #inputStreamTransformation} to the {@link InputStream} in the
  {@link FileAwareInputStream}.