class RowHashingPartitioner extends Partitioner<BulkIngestKey,Value> implements DelegatePartitioner {

    @Override
    public int getPartition(BulkIngestKey bKey, Value value, int reducers) {
        HashCodeBuilder hcb = new HashCodeBuilder(157, 41);
        Key key = bKey.getKey();
        Text cf = key.getColumnFamily();
        if (colFams.contains(cf)) {
            hcb.append(cf);
        }
        hcb.append(key.getRow());
        int partition = (hcb.toHashCode() >>> 1) % reducers;
        if (log.isTraceEnabled()) {
            log.trace("Returning " + partition + " for BIK " + bKey);
        }
        return partition;
    }

}