@Override
    public BucketWriter<IN, BucketID> createBucketWriter() {
        return new HadoopPathBasedPartFileWriter.HadoopPathBasedBucketWriter<>(
                serializableConfiguration.getConfiguration(),
                writerFactory,
                fileCommitterFactory,
                metricData,
                dirtyOptions,
                dirtySink,
                schemaUpdatePolicy,
                partitionPolicy,
                hiveShim,
                hiveVersion,
                inputFormat,
                outputFormat,
                serializationLib);
    }
Buckets builder to create buckets that use {@link HadoopPathBasedPartFileWriter}.
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/hive/src/main/java/org/apache/inlong/sort/hive/filesystem/HadoopPathBasedBulkFormatBuilder.java