@Override
  public ChangelogMode getChangelogMode() {
    if (table.isUnkeyedTable() || batchMode) {
      return ChangelogMode.insertOnly();
    }
    return ChangelogMode.newBuilder()
        .addContainedKind(RowKind.DELETE)
        .addContainedKind(RowKind.INSERT)
        .addContainedKind(RowKind.UPDATE_AFTER)
        .addContainedKind(RowKind.UPDATE_BEFORE)
        .build();
  }
Flink table api that generates mixed-format base/change file source operators.
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/table/MixedFormatFileSource.java