@Override
    public HadoopPathBasedBulkWriter<RowData> create(Path targetPath, Path inProgressPath) throws IOException {
        FileSinkOperator.RecordWriter recordWriter = factory.createRecordWriter(inProgressPath);
        Function<RowData, Writable> rowConverter = factory.createRowDataConverter();
        FileSystem fs = FileSystem.get(inProgressPath.toUri(), factory.getJobConf());
        return new InLongHadoopPathBasedBulkWriter(recordWriter, rowConverter, fs, inProgressPath);
    }
Hive bulk writer factory for path-based bulk file writer that writes to the specific hadoop path.
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/hive/src/main/java/org/apache/inlong/sort/hive/HiveBulkWriterFactory.java