jjzjj

TotalOrderPartion

全部标签

hadoop - TotalOrderPartion 与 ChainMapper

我有一个ChainMapper,它关联了2个映射器。我正在尝试对链中的最后一个映射器执行TotalOrderPartition,但没有取得很大成功。有没有办法根据链中第N个映射器的一些采样来强制执行分区?publicclassWordCountChainextendsConfiguredimplementsTool{@Overridepublicintrun(String[]args)throwsException{Jobjob=newJob(getConf(),"WordCountV1(Chain)");job.setJarByClass(getClass());FileInputF