public static MetricsGenerator getMetricsGenerator(
      boolean metricsEventLatency,
      boolean metricsEnable,
      MixedTable mixedTable,
      RowType flinkSchemaRowType,
      Schema writeSchema) {
    MetricsGenerator metricsGenerator;
    if (metricsEventLatency) {
      String modifyTimeColumn = mixedTable.properties().get(TableProperties.TABLE_EVENT_TIME_FIELD);
      metricsGenerator =
          MetricsGenerator.newGenerator(
              mixedTable.schema(), flinkSchemaRowType, modifyTimeColumn, metricsEnable);
    } else {
      metricsGenerator = MetricsGenerator.empty(metricsEnable);
    }
    return metricsGenerator;
  }
An util that loads mixed-format table, build mixed-format log writer and so on.
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/util/MixedFormatUtils.java