@Suppresswarnings( "unchecked")

protected void reduce(KEYIN key，Iterable<VALUEIN> values，Context contekt

) throws IOException，InterruptedException {

for(VALUEIN value: values) {

context.write((KEYOUT) key,(VALUEOUT) value);

}

protected void cleanup(Context context

) throws IOException，InterruptedException {

// NOTHING

}

reduce(context.getCurrentKey()，context.getValues()，context);// If a back up store is used，reset it

Iterator<VALUEIN> iter = context.getValues().iterator();if(iter instanceof ReduceContext.ValueIterator) {

((ReduceContext.ValueIterator<VALUEIN>)iter).resetBackupStore();}

}

}finally {

cleanup(context);

}