在我的reduce类中,我想使用多个输出生成多个文件。文件名应该从reduce类中生成的数据动态派生。例如,考虑到for循环,每个输出文件的名称都将对应于for循环中arraylist的第i个值。
我能在课堂上做到这一点。但是在job conf中,我无法在multipleoutputs.getnamedoutput()中设置相应的值。
我想从reduce类中的计算动态生成多个输出文件名。有没有办法做到这一点?
为了更好地解释:
在reduce课程中,我有:
mos.getcollector(路径,报告器).collect(键,值);在这里,动态生成路径没有问题,即。文件名。
但在工作中,
multipleoutputs.addnamedoutput(conf,path,textoutputformat.class,longwritable.class,text.class);问题就在这里。它必须对应于文件名,即reduce类中动态生成的路径。
有什么办法吗?或者还有其他选择吗。
请帮忙!
谢谢!!!
暂无答案!
目前还没有任何答案,快来回答吧!