甜美水杯

文章
3
资源
0
加入时间
2年10月21天

hadoop-11 自定义OutputFormat步骤Demo :数据源

步骤仿照TextOuputtFormat自定义OutputFormat。实现:根据输入源的某个非key字段输出到不同的路径。1.自定义类继承FileOutputFormat添加静态类MyRecordWriter()继承RecordWriter类,参数为reducer或mapper的输出k,v添加构造方法,参数为FSDataOutputStream。(conf->Filesystem->FSDataOutputStream)覆写write()覆写close()3.覆写g