Package | Description |
---|---|
org.apache.hadoop.mapred |
Modifier and Type | Method and Description |
---|---|
void |
FileOutputCommitter.abortTask(TaskAttemptContext context) |
abstract void |
OutputCommitter.abortTask(TaskAttemptContext taskContext)
Discard the task output.
|
void |
FileOutputCommitter.commitTask(TaskAttemptContext context) |
abstract void |
OutputCommitter.commitTask(TaskAttemptContext taskContext)
To promote the task's temporary output to final output location.
|
Path |
FileOutputCommitter.getWorkPath(TaskAttemptContext context,
Path outputPath) |
boolean |
FileOutputCommitter.needsTaskCommit(TaskAttemptContext context) |
abstract boolean |
OutputCommitter.needsTaskCommit(TaskAttemptContext taskContext)
Check whether task needs a commit.
|
void |
FileOutputCommitter.recoverTask(TaskAttemptContext context) |
void |
OutputCommitter.recoverTask(TaskAttemptContext taskContext)
Recover the task output.
|
void |
FileOutputCommitter.setupTask(TaskAttemptContext context) |
abstract void |
OutputCommitter.setupTask(TaskAttemptContext taskContext)
Sets up output for the task.
|
Copyright © 2020 Apache Software Foundation. All rights reserved.