@Internal public interface HadoopFileCommitter
Modifier and Type | Method and Description |
---|---|
void |
commit()
Commits the in-progress file to the target path.
|
void |
commitAfterRecovery()
Re-commits the in-progress file to the target path after fail-over.
|
org.apache.hadoop.fs.Path |
getTargetFilePath()
Gets the target path to commit to.
|
org.apache.hadoop.fs.Path |
getTempFilePath()
Gets the path of the intermediate file to commit.
|
void |
preCommit()
Prepares the intermediates file for committing.
|
org.apache.hadoop.fs.Path getTargetFilePath()
org.apache.hadoop.fs.Path getTempFilePath()
void preCommit() throws IOException
IOException
void commit() throws IOException
IOException
void commitAfterRecovery() throws IOException
IOException
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.