private DataStream<RowData> createDataStream(
      ProviderContext providerContext, StreamExecutionEnvironment execEnv) {
    return FlinkSource.forRowData()
        .context(providerContext)
        .env(execEnv)
        .tableLoader(loader)
        .mixedFormatTable(table)
        .project(getProjectedSchema())
        .limit(limit)
        .filters(filters)
        .flinkConf(readableConfig)
        .batchMode(execEnv.getConfiguration().get(RUNTIME_MODE).equals(BATCH))
        .watermarkStrategy(watermarkStrategy)
        .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