@Override
        public HadoopPathBasedPartFileWriter<IN, BucketID> openNewInProgressFile(BucketID bucketID,
                org.apache.flink.core.fs.Path flinkPath, long creationTime) throws IOException {

            Path path = new Path(flinkPath.toUri());
            HadoopFileCommitter fileCommitter = fileCommitterFactory.create(configuration, path);
            Path inProgressFilePath = fileCommitter.getTempFilePath();

            InLongHadoopPathBasedBulkWriter writer = (InLongHadoopPathBasedBulkWriter) bulkWriterFactory.create(path,
                    inProgressFilePath);
            JobConf jobConf = hiveWriterFactory.getJobConf();
            boolean sinkMultipleEnable = Boolean.parseBoolean(jobConf.get(SINK_MULTIPLE_ENABLE.key(), "false"));
            String sinkMultipleFormat = jobConf.get(SINK_MULTIPLE_FORMAT.key());
            String databasePattern = jobConf.get(SINK_MULTIPLE_DATABASE_PATTERN.key());
            String tablePattern = jobConf.get(SINK_MULTIPLE_TABLE_PATTERN.key());
            return new HadoopPathBasedPartFileWriter<>(bucketID,
                    path,
                    inProgressFilePath,
                    writer,
                    fileCommitter,
                    creationTime,
                    hiveShim,
                    hiveVersion,
                    sinkMultipleEnable,
                    sinkMultipleFormat,
                    databasePattern,
                    tablePattern,
                    metricData,
                    dirtyOptions,
                    dirtySink,
                    schemaUpdatePolicy,
                    partitionPolicy,
                    inputFormat,
                    outputFormat,
                    serializationLib);
        }
Factory to create {@link HadoopPathBasedPartFileWriter}. This writer does not support
snapshotting the in-progress files. For pending files, it stores the target path and the
staging file path into the state.
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/hive/src/main/java/org/apache/inlong/sort/hive/filesystem/HadoopPathBasedPartFileWriter.java