OutputFormat类——Hadoop

Dear 丶 2022-08-22 05:49 206阅读 0赞

1、OutputFormat是一个用于描述MapReduce作业的输出格式和规范的抽象类，位于org.apache.hadoop.mapreduce.OutputFormat<K, V>. Mapreduce框架依靠文件输出格式完成输出规范检查（如检查目录是否存在），并为文件输出格式提供作业结果数据输出的功能，即提供RecordWriter的实现，输出文件被存储在文件系统FileSystem中。

2、如果用户要基于Hadooop内置的输出格式和内置的RecordWriter进行定制，则需要重载OutputFormat类的getRecordWriter()方法以便获取新的RecordWriter；如果完全基于抽想的输出格式类OutputFormat和抽象的RecordWriter类进行全新的程序定制，则需要实现OutputFormat中的getRecordWriter（）等抽象方法。

3、此外，OutputFormat类还包括一个getOutputCommiter()方法来负责确保输出被正确提交，以及一个检查作业输出规范有效性的方法checkOutputSecs（）。

4、FileOutputFormat类

①写入到HDFS的所有OutputFormat类都继承自FileOutputFormat类，直接已知的子类有MapFileOutputFormat，MultipleOutputFormat，SequenceFileOutputFormat和TextOutputFormat

②FileOutputFormat类提供了若干静态方法，用户可以用它们进行输入路径设置、分块大小设置等全局设置。

setOutputPath()方法设置Mapreduce任务输出目录的路径，getRecordWriter（）方法获得当前给定任务的RecordWriter类型；setOutputName（）方法设置要创建的输出文件的名称

5、TextOutputFormat类 是默认的输出格式，它把每条记录写成文本行。由于TextOutputFormat调用toString（）方法把键和值转换为字符串，他的键和值可以是任意的类型。

6.SequenceFileOutputFormat类

SequenceFileOutputFormat将他的输出写为一个二进制顺序文件。由于他的格式紧凑，很容易被压缩，因此如果输出需要作为后续的MapReduce任务的输入，这便是一个很好的输出格式。

7、NullOutputFormat类

NullOutputFormat是继承自OutputFormat类的一个抽象类，位于org.apache.hadoop.mapreduce.lib.output.NullOutputFormat<K, V>,它会消耗掉所有输出，并把他们赋值为null

8、RecordWriter

①对于一个文件输出格式，都需要有一个对应的数据记录输出RecordWriter，以便系统mingque输出结果写入到文件中的具体格式。RecordWriter是一个抽象类，位于org。apache。hadoop。mapreduce。RecordWriter<K, V>