mapreduce 文件输出的标题
Title for mapreduce file output
我正在开发一个基于 MapReduce 的应用程序,我想从进程内部添加到我的输出文件(txt 文件)标题。
这是我目前的输出:
Streptococcus_suis2 41581
Streptococcus_suis3 41581
这是我希望文件的样子:
示例 1
Streptococcus_suis2 41581
Streptococcus_suis3 41581
有人有想法吗?
我假设您正在使用 TextOutputFormat
并通过调用 context.write(key,value);
写入数据
来自
类型的减速器
MyReducer extends Reducer<InKey,InValue,Text,LongWritable>
您可以覆盖减速器的 setup
方法:
@Override
protected void setup(Context context) {
context.write(new Text("Sample1"),null);
}
并使用 null 作为第二个参数调用 context.write 以将 header 行添加到输出文件。
我正在开发一个基于 MapReduce 的应用程序,我想从进程内部添加到我的输出文件(txt 文件)标题。 这是我目前的输出:
Streptococcus_suis2 41581
Streptococcus_suis3 41581
这是我希望文件的样子:
示例 1
Streptococcus_suis2 41581
Streptococcus_suis3 41581
有人有想法吗?
我假设您正在使用 TextOutputFormat
并通过调用 context.write(key,value);
写入数据
来自
MyReducer extends Reducer<InKey,InValue,Text,LongWritable>
您可以覆盖减速器的 setup
方法:
@Override
protected void setup(Context context) {
context.write(new Text("Sample1"),null);
}
并使用 null 作为第二个参数调用 context.write 以将 header 行添加到输出文件。