@Override
  public void applyWatermark(WatermarkStrategy<RowData> watermarkStrategy) {
    Configuration conf = Configuration.fromMap(table.properties());
    boolean dimTable =
        CompatibleFlinkPropertyUtil.propertyAsBoolean(conf, MixedFormatValidator.DIM_TABLE_ENABLE);
    if (!dimTable) {
      this.watermarkStrategy = watermarkStrategy;
    }
  }
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