(final Context context)
| 251 | } |
| 252 | |
| 253 | @Override |
| 254 | public void cleanup(final Context context) throws IOException, InterruptedException { |
| 255 | writeVEvalToContext(accum,context); |
| 256 | log.info("processed " + nProcessed + " on " + hostDescr); |
| 257 | log.info(".cleanup() " + hostDescr); |
| 258 | burster = null; |
| 259 | config = null; |
| 260 | defs = null; |
| 261 | accum = null; |
| 262 | } |
| 263 | } |
| 264 | |
| 265 | public static final class SumReducer extends Reducer<Text,DoubleWritable,Text,DoubleWritable> { // TODO: check if there is a standard summer we could use here |
nothing calls this directly
no test coverage detected