我有两个来源的信息：
在窗体中Map输出，

output.collect(new StockKey(Text(x+" "+id), new Text(id2)), new Text(data));

在窗体中Map输出，

output.collect(new StockKey(new Text(x+" "+id), new Text(1), new Text(data));

作业配置：

conf.setPartitionerClass(CustomPartitioner.class);
 conf.setValueGroupingComparatorClass(StockKeyGroupingComparator.class);

其中stockkey是一个自定义的格式类 (new Text(), new Text()) ;
施工单位：

public StockKey(){
    this.symbol = new Text();
    this.timestamp = new Text();
}

分组比较器：

public class StockKeyGroupingComparator extends WritableComparator {

    protected StockKeyGroupingComparator() {
        super(StockKey.class, true);
    }  

    public int compare(WritableComparable w1, WritableComparable w2){
        StockKey k1 = (StockKey)w1;
        StockKey k2 = (StockKey)w2;

        Text x1 = new Text(k1.getSymbol());
        Text x2 = new Text(k2.getSymbol());

        return x1.compareTo(x2);

    }

}

但我并没有从输入中接收map输出值
我得到的只是Map的输出值到达了减速机。我要有符号的唱片 new Text(x+" "+id) 这两个Map输出共用，将分组到同一个减速机。我被打动了。
请帮帮我！