code: @Override
      public void flush() throws IOException, InterruptedException {
          for (Entry<Key, List<Value>> entry : buffer.entrySet()) {
              summarizer.combine(entry.getKey(), entry.getValue(), context);
              entry.getValue().clear();
          }
          buffer.clear();
      }
docs: {@inheritDoc}