|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectorg.apache.hadoop.mapreduce.OutputCommitter
org.apache.hadoop.mapred.OutputCommitter
OutputCommitter instead.
@Deprecated public abstract class OutputCommitter
OutputCommitter describes the commit of task output for a
Map-Reduce job.
The Map-Reduce framework relies on the OutputCommitter of
the job to:
FileOutputCommitter,
JobContext,
TaskAttemptContext| Constructor Summary | |
|---|---|
OutputCommitter()
Deprecated. |
|
| Method Summary | |
|---|---|
abstract void |
abortTask(TaskAttemptContext taskContext)
Deprecated. Discard the task output |
void |
abortTask(TaskAttemptContext taskContext)
Deprecated. This method implements the new interface by calling the old method. |
abstract void |
cleanupJob(JobContext jobContext)
Deprecated. For cleaning up the job's output after job completion |
void |
cleanupJob(JobContext context)
Deprecated. This method implements the new interface by calling the old method. |
abstract void |
commitTask(TaskAttemptContext taskContext)
Deprecated. To promote the task's temporary output to final output location The task's output is moved to the job's output directory. |
void |
commitTask(TaskAttemptContext taskContext)
Deprecated. This method implements the new interface by calling the old method. |
abstract boolean |
needsTaskCommit(TaskAttemptContext taskContext)
Deprecated. Check whether task needs a commit |
boolean |
needsTaskCommit(TaskAttemptContext taskContext)
Deprecated. This method implements the new interface by calling the old method. |
abstract void |
setupJob(JobContext jobContext)
Deprecated. For the framework to setup the job output during initialization |
void |
setupJob(JobContext jobContext)
Deprecated. This method implements the new interface by calling the old method. |
abstract void |
setupTask(TaskAttemptContext taskContext)
Deprecated. Sets up output for the task. |
void |
setupTask(TaskAttemptContext taskContext)
Deprecated. This method implements the new interface by calling the old method. |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
|---|
public OutputCommitter()
| Method Detail |
|---|
public abstract void setupJob(JobContext jobContext)
throws IOException
jobContext - Context of the job whose output is being written.
IOException - if temporary output could not be created
public abstract void cleanupJob(JobContext jobContext)
throws IOException
jobContext - Context of the job whose output is being written.
IOException
public abstract void setupTask(TaskAttemptContext taskContext)
throws IOException
taskContext - Context of the task whose output is being written.
IOException
public abstract boolean needsTaskCommit(TaskAttemptContext taskContext)
throws IOException
taskContext -
IOException
public abstract void commitTask(TaskAttemptContext taskContext)
throws IOException
taskContext - Context of the task whose output is being written.
IOException - if commit is not
public abstract void abortTask(TaskAttemptContext taskContext)
throws IOException
taskContext -
IOException
public final void setupJob(JobContext jobContext)
throws IOException
setupJob in class OutputCommitterjobContext - Context of the job whose output is being written.
IOException - if temporary output could not be created
public final void cleanupJob(JobContext context)
throws IOException
cleanupJob in class OutputCommittercontext - Context of the job whose output is being written.
IOException
public final void setupTask(TaskAttemptContext taskContext)
throws IOException
setupTask in class OutputCommittertaskContext - Context of the task whose output is being written.
IOException
public final boolean needsTaskCommit(TaskAttemptContext taskContext)
throws IOException
needsTaskCommit in class OutputCommitterIOException
public final void commitTask(TaskAttemptContext taskContext)
throws IOException
commitTask in class OutputCommittertaskContext - Context of the task whose output is being written.
IOException - if commit is not
public final void abortTask(TaskAttemptContext taskContext)
throws IOException
abortTask in class OutputCommitterIOException
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||