@InterfaceAudience.Public @InterfaceStability.Stable public class NullOutputFormat<K,V> extends OutputFormat<K,V>
Constructor and Description |
---|
NullOutputFormat() |
Modifier and Type | Method and Description |
---|---|
void |
checkOutputSpecs(JobContext context)
Check for validity of the output-specification for the job.
|
OutputCommitter |
getOutputCommitter(TaskAttemptContext context)
Get the output committer for this output format.
|
RecordWriter<K,V> |
getRecordWriter(TaskAttemptContext context)
Get the
RecordWriter for the given task. |
public RecordWriter<K,V> getRecordWriter(TaskAttemptContext context)
OutputFormat
RecordWriter
for the given task.getRecordWriter
in class OutputFormat<K,V>
context
- the information about the current task.RecordWriter
to write the output for the job.public void checkOutputSpecs(JobContext context)
OutputFormat
This is to validate the output specification for the job when it is a job is submitted. Typically checks that it does not already exist, throwing an exception when it already exists, so that output is not overwritten.
checkOutputSpecs
in class OutputFormat<K,V>
context
- information about the jobpublic OutputCommitter getOutputCommitter(TaskAttemptContext context)
OutputFormat
getOutputCommitter
in class OutputFormat<K,V>
context
- the task contextCopyright © 2019 Apache Software Foundation. All rights reserved.