I'm noticing the "group" key isn't used very often in panel examples.
This makes sense - the reducer value input schema is a superset of that in the keys.
That being the case - and given that the data model only uses "group by" internally to group keys before reducing - why not simplify the TupleReducer(..) signature to :
@Override
public void reduce(Iterable<ITuple> tuples, TupleMRContext context, Collector collector) throws IOException, InterruptedException, TupleMRException
{
}
Or alternatively, maybe the grouping parameter is not needed in the ITuple values.
Just a suggestion - let me know if I'm missing something.
--
Jay Vyas
http://jayunit100.blogspot.com