@InterfaceAudience.Public @InterfaceStability.Evolving public abstract class PathOutputCommitter extends OutputCommitter
FileOutputCommitter
.
There are two constructors, both of which do nothing but long and
validate their arguments.Modifier | Constructor and Description |
---|---|
protected |
PathOutputCommitter(Path outputPath,
JobContext context)
Constructor for a job attempt.
|
protected |
PathOutputCommitter(Path outputPath,
TaskAttemptContext context)
Constructor for a task attempt.
|
Modifier and Type | Method and Description |
---|---|
abstract Path |
getOutputPath()
Get the final directory where work will be placed once the job
is committed.
|
abstract Path |
getWorkPath()
Get the directory that the task should write results into.
|
boolean |
hasOutputPath()
Predicate: is there an output path?
|
String |
toString() |
abortJob, abortTask, cleanupJob, commitJob, commitTask, isCommitJobRepeatable, isRecoverySupported, isRecoverySupported, needsTaskCommit, recoverTask, setupJob, setupTask
protected PathOutputCommitter(Path outputPath, TaskAttemptContext context) throws IOException
outputPath
- output path: may be nullcontext
- task contextIOException
- IO problemprotected PathOutputCommitter(Path outputPath, JobContext context) throws IOException
outputPath
- output path: may be nullcontext
- task contextIOException
- IO problempublic abstract Path getOutputPath()
public boolean hasOutputPath()
public abstract Path getWorkPath() throws IOException
IOException
- IO problemCopyright © 2024 Apache Software Foundation. All rights reserved.