code: @Override
      public void write(String output) throws MapReduceException {
          try {
              writer.write(output + DataUtilDefaults.lineTerminator);
          } catch (IOException e) {
              throw new MapReduceException("Failed to write to the output collector", e);
          }
      }
docs: Write to the output collector
  @param output data to write
  @exception MapReduceException map reduce exception