### Question:
RowHashingPartitioner extends Partitioner<BulkIngestKey,Value> implements DelegatePartitioner { @Override public void setConf(Configuration conf) { this.conf = conf; configure(COLUMN_FAMILIES); }  @Override int getPartition(BulkIngestKey bKey, Value value, int reducers); @Override Configuration getConf(); @Override void setConf(Configuration conf); @Override void configureWithPrefix(String prefix); @Override int getNumPartitions(); @Override void initializeJob(Job job); static final String COLUMN_FAMILIES; }### Answer:
@Test public void testShardAndCFPartitioning() { RowHashingPartitioner sdp = new RowHashingPartitioner(); Configuration conf = new Configuration(); conf.set(RowHashingPartitioner.COLUMN_FAMILIES, "tf"); sdp.setConf(conf); assertColumnFamilyPartitioning(sdp); }