protected TaskDataWriter<T> newWriter(TaskWriterKey writerKey) {
      DataWriter<T> dataWriter =
          io.doAs(
              () ->
                  appenderFactory.newDataWriter(
                      outputFileFactory.newOutputFile(writerKey),
                      format,
                      writerKey.getPartitionKey()));
      return new TaskDataWriter<>(dataWriter, io);
    }
Wrap the data as a {@link StructLike}.
amoro-format-iceberg/src/main/java/org/apache/amoro/io/writer/BaseTaskWriter.java