I'm looking at implementing an advanced Reducer by overriding the Reducer.run()
method. Seems straightforward enough but looking at the default implementation
it invokes:
((ReduceContext.ValueIterator)
(context.getValues().iterator())).resetBackupStore();
The problem is that ReducerContext.ValueIterator is package protected. Looking
at the resetBackupStore() method, it doesn't look optional, or at least seems
important.
ChainReducer overrides run() but does not invoke resetBackupStore() ...
Has anyone written a Reducer by overriding the run() method? Used or didn't use
resetBackupStore()? Made any difference?
