@InterfaceAudience.Public @InterfaceStability.Stable public class TextOutputFormat<K,V> extends FileOutputFormat<K,V>
OutputFormat
that writes plain text files.Modifier and Type | Field and Description |
---|---|
static String |
SEPERATOR |
BASE_OUTPUT_NAME, COMPRESS, COMPRESS_CODEC, COMPRESS_TYPE, OUTDIR, 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 static String SEPERATOR
public RecordWriter<K,V> getRecordWriter(TaskAttemptContext job) throws IOException, 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.IOException
InterruptedException
Copyright © 2019 Apache Software Foundation. All rights reserved.