Uses of Interface
org.apache.flink.formats.hadoop.bulk.HadoopFileCommitter
-
Packages that use HadoopFileCommitter Package Description org.apache.flink.formats.hadoop.bulk org.apache.flink.formats.hadoop.bulk.committer -
-
Uses of HadoopFileCommitter in org.apache.flink.formats.hadoop.bulk
Methods in org.apache.flink.formats.hadoop.bulk that return HadoopFileCommitter Modifier and Type Method Description HadoopFileCommitterDefaultHadoopFileCommitterFactory. create(org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.fs.Path targetFilePath)HadoopFileCommitterHadoopFileCommitterFactory. create(org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.fs.Path targetFilePath)Creates a new Hadoop file committer for writing.HadoopFileCommitterDefaultHadoopFileCommitterFactory. recoverForCommit(org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.fs.Path targetFilePath, org.apache.hadoop.fs.Path tempFilePath)HadoopFileCommitterHadoopFileCommitterFactory. recoverForCommit(org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.fs.Path targetFilePath, org.apache.hadoop.fs.Path inProgressPath)Creates a Hadoop file committer for commit the pending file.Constructors in org.apache.flink.formats.hadoop.bulk with parameters of type HadoopFileCommitter Constructor Description HadoopPathBasedPartFileWriter(BucketID bucketID, HadoopPathBasedBulkWriter<IN> writer, HadoopFileCommitter fileCommitter, long createTime) -
Uses of HadoopFileCommitter in org.apache.flink.formats.hadoop.bulk.committer
Classes in org.apache.flink.formats.hadoop.bulk.committer that implement HadoopFileCommitter Modifier and Type Class Description classHadoopRenameFileCommitterThe Hadoop file committer that directly rename the in-progress file to the target file.
-