Description
The Java mapreduce API added in AVRO-493 requires reducers implementations to explicitly detect sequences of matching data.
Rather the reduce method might better look something like:
void reduce(Iterator<IN>, Collector<OUT>);
Where all equal values are passed in a single call.
Attachments
Attachments
Issue Links
- is duplicated by
-
AVRO-581 java: add reducer that separates keys and values when map output is pairs
-
- Closed
-