@Override
  public void abort() throws IOException {
    writerHolder.close();
    List<DataFile> completedFiles = writerHolder.completedFiles();

    // clean up files created by this writer
    Tasks.foreach(completedFiles)
        .throwFailureWhenFinished()
        .noRetry()
        .run(file -> io.deleteFile(file.path().toString()));
  }
Abstract implementation of writer for {@link BaseTable}.

@param <T> to indicate the record data type.
amoro-format-iceberg/src/main/java/org/apache/amoro/io/writer/BaseTaskWriter.java