我正在开发一个基于mapreduce的应用程序,我想从进程内部添加到我的输出文件(txt文件)标题。这是我当前的输出:Pig链球菌2 41581Pig链球菌3 41581这就是我想要的文件的样子:样本1Pig链球菌2 41581Pig链球菌3 41581有人有主意吗?
xqnpmsa81#
我猜你在用 TextOutputFormat 通过呼叫 context.write(key,value); 从你的减速机类型
TextOutputFormat
context.write(key,value);
MyReducer extends Reducer<InKey,InValue,Text,LongWritable>
您可以覆盖 setup 减速机的方法:
setup
@Override protected void setup(Context context) { context.write(new Text("Sample1"),null); }
并调用context.write,将null作为第二个参数,将头行添加到输出文件中。
1条答案
按热度按时间xqnpmsa81#
我猜你在用
TextOutputFormat
通过呼叫context.write(key,value);
从你的减速机类型您可以覆盖
setup
减速机的方法:并调用context.write,将null作为第二个参数,将头行添加到输出文件中。