docs: public void collect(Object writableComparable, Object writable) throws IOException {
      if (hadoopFlowProcess instanceof HadoopFlowProcess)
        ((HadoopFlowProcess) hadoopFlowProcess).getReporter().progress();
  
      writer.write(writableComparable, writable);
    }