public static ChangeAction transformFromFlinkRowKind(RowKind rowKind) {
    switch (rowKind) {
      case INSERT:
        return ChangeAction.INSERT;
      case UPDATE_BEFORE:
        return ChangeAction.UPDATE_BEFORE;
      case UPDATE_AFTER:
        return ChangeAction.UPDATE_AFTER;
      case DELETE:
        return ChangeAction.DELETE;
      default:
        throw new IllegalArgumentException("This is unsupported RowKind:" + rowKind);
    }
  }
An util that converts between {@link RowKind} and {@link ChangeAction}.
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common-format/src/main/java/org/apache/amoro/flink/shuffle/RowKindUtil.java