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

    writer.write(writableComparable, writable);
  }
public void collect ( Object writableComparable , Object writable ) throws IOException { if ( hadoopFlowProcess instanceof HadoopFlowProcess ) ( ( HadoopFlowProcess ) hadoopFlowProcess ) . getReporter ( ) . progress ( ) ; writer . write ( writableComparable , writable ) ; }
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