@Override
  public void addReader(int subtaskId) {
    LOG.info("Added reader: {}", subtaskId);
  }
The abstract mixed-format source enumerator.
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/read/hybrid/enumerator/AbstractMixedFormatEnumerator.java