Hi,
Not sure if this can be done.
Here's a relevant snippet of code:
{
super(inputCounter, conf, reporter);
combinerClass = cls;
keyClass = (Class<K>) job.getMapOutputKeyClass();
valueClass = (Class<V>) job.getMapOutputValueClass();
comparator = (RawComparator<K>) job.getOutputKeyComparator();
}
This leads me to believe combiners don't get reference to grouping comparator,
just the key comparator.
Amogh
On 3/8/10 12:11 PM, "Bae, Jae Hyeon" <[email protected]> wrote:
Hi
I am writing map-reduce program with hadoop-0.20.1, new mapreduce api.
I applied GroupComparator with
job.setGroupingComparatorClass(GroupComparator.class);, but it does
not seem to work in combiner.
If I want to apply GroupingComparator in combiner, what should I do?
Regards Jae
