OutputCommitter committer,
RawComparator comparator) throws IOException, InterruptedException {
StatusReporter reporter = new MockStatusReporter();
<<<<<<< HEAD
ReduceContext context = new ReduceContextImpl(
configuration, id, reader,
reporter.getCounter("asakusafw", "inputKey"),
reporter.getCounter("asakusafw", "inputValue"),
writer, committer, reporter, comparator, inputKeyClass, inputValueClass);
return new WrappedReducer().getReducerContext(context);
=======
return reducer.new Context(
configuration,
id,
reader,
reporter.getCounter("asakusafw", "inputKey"), //$NON-NLS-1$ //$NON-NLS-2$
reporter.getCounter("asakusafw", "inputValue"), //$NON-NLS-1$ //$NON-NLS-2$
writer, committer, reporter, comparator,
inputKeyClass, inputValueClass);
>>>>>>> e7790cc1e28671e603df554cb389a07eedaf8a58
}
/** |