public Put getJobProcessedSuccessPut(byte[] row, boolean success) {
    Put put = new Put(row);
    put.addColumn(Constants.INFO_FAM_BYTES,
        Constants.JOB_PROCESSED_SUCCESS_COL_BYTES, Bytes.toBytes(success));
    if (success) {
      // Make sure we mark that this row does not have to be reloaded, no matter
      // if it is the first time, or it was marked with reload before.
      put.addColumn(Constants.INFO_FAM_BYTES, Constants.RAW_COL_REPROCESS_BYTES,
          Bytes.toBytes(false));
    }
    return put;
  }
public Put getJobProcessedSuccessPut ( byte [ ] row , boolean success ) { Put put = new Put ( row ) ; put . addColumn ( Constants . INFO_FAM_BYTES , Constants . JOB_PROCESSED_SUCCESS_COL_BYTES , Bytes . toBytes ( success ) ) ; if ( success ) { put . addColumn ( Constants . INFO_FAM_BYTES , Constants . RAW_COL_REPROCESS_BYTES , Bytes . toBytes ( false ) ) ; } return put ; }
@param row the identifier of the row in the RAW table. Cannot be null.
@success whether the job was processed successfully or not
@return a put to indicate that this job has been processed successfully.