@Override
    public void processElement(I value, Context ctx, Collector<Object> out) throws Exception {
        if (this.writerHelper == null) {
            initWriterHelper();
        }
        this.writerHelper.write((RowData) value);
        if (sinkMetricData != null) {
            sinkMetricData.invokeWithEstimate(value);
        }
    }
Constructs an AppendWriteFunction.

@param config The config options
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/hudi/src/main/java/org/apache/inlong/sort/hudi/sink/append/AppendWriteFunction.java