private BucketsBuilder<RowData, String, ? extends BucketsBuilder<RowData, ?, ?>> bucketsBuilderForMRWriter(
            HiveWriterFactory recordWriterFactory,
            StorageDescriptor sd,
            TableBucketAssigner assigner,
            HiveRollingPolicy rollingPolicy,
            OutputFileConfig outputFileConfig) {
        HiveBulkWriterFactory hadoopBulkFactory = new HiveBulkWriterFactory(recordWriterFactory);
        return new HadoopPathBasedBulkFormatBuilder<>(new Path(sd.getLocation()), hadoopBulkFactory, jobConf, assigner,
                dirtyOptions, dirtySink, schemaUpdatePolicy, partitionPolicy, hiveShim, hiveVersion,
                sinkMultipleEnable, inputFormat, outputFormat, serializationLib)
                        .withRollingPolicy(rollingPolicy)
                        .withOutputFileConfig(outputFileConfig);
    }
Table sink to write to Hive tables.
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/hive/src/main/java/org/apache/inlong/sort/hive/HiveTableSink.java