Package | Description |
---|---|
org.apache.flink.formats.hadoop.bulk | |
org.apache.flink.formats.hadoop.bulk.committer |
Modifier and Type | Method and Description |
---|---|
HadoopFileCommitter |
DefaultHadoopFileCommitterFactory.create(Configuration configuration,
org.apache.hadoop.fs.Path targetFilePath) |
HadoopFileCommitter |
HadoopFileCommitterFactory.create(Configuration configuration,
org.apache.hadoop.fs.Path targetFilePath)
Creates a new Hadoop file committer for writing.
|
HadoopFileCommitter |
DefaultHadoopFileCommitterFactory.recoverForCommit(Configuration configuration,
org.apache.hadoop.fs.Path targetFilePath,
org.apache.hadoop.fs.Path tempFilePath) |
HadoopFileCommitter |
HadoopFileCommitterFactory.recoverForCommit(Configuration configuration,
org.apache.hadoop.fs.Path targetFilePath,
org.apache.hadoop.fs.Path inProgressPath)
Creates a Hadoop file committer for commit the pending file.
|
Constructor and Description |
---|
HadoopPathBasedPartFileWriter(BucketID bucketID,
HadoopPathBasedBulkWriter<IN> writer,
HadoopFileCommitter fileCommitter,
long createTime) |
Modifier and Type | Class and Description |
---|---|
class |
HadoopRenameFileCommitter
The Hadoop file committer that directly rename the in-progress file to the target file.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.