@Override
  public void processElement(StreamRecord<RowData> element) throws Exception {
    if (metricsGenerator.isMetricEnable()) {
      meterSpeed.markEvent();
    }
    if (logWriter != null) {
      logWriter.processElement(element);
    }
    if (fileWriter instanceof Input) {
      ((Input) fileWriter).processElement(element);
    }
    metricsGenerator.recordLatency(element);
  }
This is the general entry of an mixed-format writer that wraps different operators insides.

@param <OUT>
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/write/MixedFormatWriter.java