// Setup the set for monitoring private IntWritable result = new IntWritable(); public void reduce(Text key, Iterable values, Context context) throws IOException, InterruptedException { HashSet MonitorSet =new HashSet(); MonitorSet.add("05F0001N"); MonitorSet.add("05F0055N"); MonitorSet.add("05F0287N"); MonitorSet.add("05F0309N"); MonitorSet.add("05F0438N"); MonitorSet.add("05F0528N"); String KeyStr = key.toString(); Boolean CheckFlag = false; for (String OneKey : MonitorSet) { if (KeyStr.contains(OneKey)){ CheckFlag = true; break; } } // End of for (String OneKey : MonitorSet) if (CheckFlag == true) { int sum = 0; for (IntWritable val : values) { sum += val.get(); } result.set(sum); context.write(key, result); } //End of if (CheckFlag == true) { } // End of public void reduce(Text key, Iterable values, Context context)