我正在创建自己的减速机,如下所示:
public class MyReducer implemts Reducer<K1,V1,K2,V2>{
@override
public void configure(JobConf conf){
}
@override
public void close(JobConf conf){
}
public void reduce(parsms ){
}
}
}
如何输出自定义csv头文件?我没有扩展Map程序,因此无法覆盖设置方法。
1条答案
按热度按时间oalqel3c1#
您正在查看旧的hadoopapi。
在新的api中,您可以重写reducer的setup方法,创建头。
请看http://hadoop.apache.org/docs/stable/api/org/apache/hadoop/mapreduce/reducer.html.