public class TextOutputFormat<K,V> extends FileOutputFormat<K,V>
OutputFormat
that writes plain text files.Modifier and Type | Class and Description |
---|---|
protected static class |
TextOutputFormat.LineRecordWriter<K,V> |
BASE_OUTPUT_NAME, PART
Constructor and Description |
---|
TextOutputFormat() |
Modifier and Type | Method and Description |
---|---|
RecordWriter<K,V> |
getRecordWriter(TaskAttemptContext job)
Get the
RecordWriter for the given task. |
checkOutputSpecs, getCompressOutput, getDefaultWorkFile, getOutputCommitter, getOutputCompressorClass, getOutputName, getOutputPath, getPathForWorkFile, getUniqueFile, getWorkOutputPath, setCompressOutput, setOutputCompressorClass, setOutputName, setOutputPath
public RecordWriter<K,V> getRecordWriter(TaskAttemptContext job) throws java.io.IOException, java.lang.InterruptedException
OutputFormat
RecordWriter
for the given task.getRecordWriter
in class FileOutputFormat<K,V>
job
- the information about the current task.RecordWriter
to write the output for the job.java.io.IOException
java.lang.InterruptedException
Copyright © 2009 The Apache Software Foundation