org.apache.hadoop.examples.terasort

类 TeraOutputFormat

java.lang.Object

org.apache.hadoop.mapred.FileOutputFormat<K,V>

org.apache.hadoop.mapred.TextOutputFormat<Text,Text>

org.apache.hadoop.examples.terasort.TeraOutputFormat

所有已实现的接口:

OutputFormat<Text,Text>

public class TeraOutputFormat
extends TextOutputFormat<Text,Text>

A streamlined text output format that writes key, value, and "\r\n".

嵌套类概要

从类继承的嵌套类/接口 org.apache.hadoop.mapred.TextOutputFormat

TextOutputFormat.LineRecordWriter<K,V>

从类继承的嵌套类/接口 org.apache.hadoop.mapred.FileOutputFormat

FileOutputFormat.Counter

构造器概要

构造器

构造器和说明
TeraOutputFormat()

方法概要

方法

限定符和类型	方法和说明
static boolean	getFinalSync(JobConf conf) Does the user want a final sync at close?
RecordWriter<Text,Text>	getRecordWriter(FileSystem ignored, JobConf job, String name, Progressable progress) Get the RecordWriter for the given job.
static void	setFinalSync(JobConf conf, boolean newValue) Set the requirement for a final sync before the stream is closed.

从类继承的方法 org.apache.hadoop.mapred.FileOutputFormat

checkOutputSpecs, getCompressOutput, getOutputCompressorClass, getOutputPath, getPathForCustomFile, getTaskOutputPath, getUniqueName, getWorkOutputPath, setCompressOutput, setOutputCompressorClass, setOutputPath

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

TeraOutputFormat

public TeraOutputFormat()

方法详细资料

setFinalSync

public static void setFinalSync(JobConf conf,
                boolean newValue)

Set the requirement for a final sync before the stream is closed.

getFinalSync

public static boolean getFinalSync(JobConf conf)

Does the user want a final sync at close?

getRecordWriter

public RecordWriter<Text,Text> getRecordWriter(FileSystem ignored,
                                      JobConf job,
                                      String name,
                                      Progressable progress)
                                        throws IOException

从接口复制的说明: OutputFormat

Get the RecordWriter for the given job.

指定者:

getRecordWriter 在接口中 OutputFormat<Text,Text>

覆盖:

getRecordWriter 在类中 TextOutputFormat<Text,Text>

job - configuration for the job whose output is being written.

name - the unique name for this part of the output.

progress - mechanism for reporting progress while writing to file.

返回:

a RecordWriter to write the output for the job.

抛出:

IOException