code: public void collect(Object writableComparable, Object writable) throws IOException {
      if (hadoopFlowProcess instanceof HadoopFlowProcess)
        ((HadoopFlowProcess) hadoopFlowProcess).getReporter().progress();
  
      writer.write(writableComparable, writable);
    }
docs: Method collect writes the given values to the {@link Tap} this instance
  encapsulates.
  
  @param writableComparable
  of type WritableComparable
  @param writable
  of type Writable
  @throws IOException
  when