public class DefaultHadoopFileCommitterFactory extends Object implements HadoopFileCommitterFactory
HadoopRenameFileCommitter
.Constructor and Description |
---|
DefaultHadoopFileCommitterFactory() |
Modifier and Type | Method and Description |
---|---|
HadoopFileCommitter |
create(Configuration configuration,
org.apache.hadoop.fs.Path targetFilePath)
Creates a new Hadoop file committer for writing.
|
HadoopFileCommitter |
recoverForCommit(Configuration configuration,
org.apache.hadoop.fs.Path targetFilePath,
org.apache.hadoop.fs.Path tempFilePath)
Creates a Hadoop file committer for commit the pending file.
|
public HadoopFileCommitter create(Configuration configuration, org.apache.hadoop.fs.Path targetFilePath) throws IOException
HadoopFileCommitterFactory
create
in interface HadoopFileCommitterFactory
configuration
- The hadoop configuration.targetFilePath
- The target path to commit to.IOException
public HadoopFileCommitter recoverForCommit(Configuration configuration, org.apache.hadoop.fs.Path targetFilePath, org.apache.hadoop.fs.Path tempFilePath) throws IOException
HadoopFileCommitterFactory
recoverForCommit
in interface HadoopFileCommitterFactory
configuration
- The hadoop configuration.targetFilePath
- The target path to commit to.tempFilePath
- The path of the remaining pending file.IOException
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.