@Override
  protected ChangeAction action(RowData data) {
    switch (data.getRowKind()) {
      case DELETE:
        return ChangeAction.DELETE;
      case INSERT:
        return ChangeAction.INSERT;
      case UPDATE_BEFORE:
        return ChangeAction.UPDATE_BEFORE;
      case UPDATE_AFTER:
        return ChangeAction.UPDATE_AFTER;
    }
    return ChangeAction.INSERT;
  }
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