Package | Description |
---|---|
org.apache.hadoop.mapred |
Modifier and Type | Method and Description |
---|---|
void |
OutputCommitter.abortJob(JobContext jobContext,
int status)
For aborting an unsuccessful job's output.
|
void |
FileOutputCommitter.abortJob(JobContext context,
int runState) |
void |
OutputCommitter.cleanupJob(JobContext jobContext)
Deprecated.
|
void |
FileOutputCommitter.cleanupJob(JobContext context)
Deprecated.
|
void |
OutputCommitter.commitJob(JobContext jobContext)
For committing job's output after successful job completion.
|
void |
FileOutputCommitter.commitJob(JobContext context) |
boolean |
OutputCommitter.isCommitJobRepeatable(JobContext jobContext)
Returns true if an in-progress job commit can be retried.
|
boolean |
FileOutputCommitter.isCommitJobRepeatable(JobContext context) |
boolean |
OutputCommitter.isRecoverySupported(JobContext jobContext)
Is task output recovery supported for restarting jobs?
If task output recovery is supported, job restart can be done more
efficiently.
|
boolean |
FileOutputCommitter.isRecoverySupported(JobContext context) |
abstract void |
OutputCommitter.setupJob(JobContext jobContext)
For the framework to setup the job output during initialization.
|
void |
FileOutputCommitter.setupJob(JobContext context) |
Copyright © 2022 Apache Software Foundation. All rights reserved.