@Override
    public void processElement(I value, ProcessFunction<I, Object>.Context ctx, Collector<Object> out)
            throws Exception {
        bufferRecord((HoodieRecord<?>) value);
        if (sinkMetricData != null) {
            sinkMetricData.invokeWithEstimate(value);
        }
    }
Constructs a StreamingSinkFunction.

@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/StreamWriteFunction.java