@Override
  public void write(RowData row) throws IOException {
    processMultiUpdateAfter(row);
    if (upsert && RowKind.INSERT.equals(row.getRowKind())) {
      row.setRowKind(RowKind.DELETE);
      super.write(row);
      row.setRowKind(RowKind.INSERT);
    }
    super.write(row);
  }
task writer for {@link KeyedTable#changeTable()} ()}. Dev should make sure outputFileFactory
write to change table's location
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/write/FlinkChangeTaskWriter.java