public static <I> WriteOperatorFactory<I> getFactory(Configuration conf, MetricOption metricOption) {
        return WriteOperatorFactory.instance(conf, new BucketStreamWriteOperator<>(conf, metricOption));
    }
Operator for {@link BucketStreamWriteFunction}.

@param <I> The input type
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/hudi/src/main/java/org/apache/inlong/sort/hudi/sink/bucket/BucketStreamWriteOperator.java