public TaskDataWriter<T> get(DataWriterKey writerKey) throws IOException {
      if (closed) {
        throw new IllegalStateException("The task writer has already been closed.");
      }
      return getDataWriter(writerKey);
    }
Wrap the data as a {@link StructLike}.
amoro-format-iceberg/src/main/java/org/apache/amoro/io/writer/BaseTaskWriter.java