### Question:
HTableUtil { public static void bucketRsPut(HTable htable, List<Put> puts) throws IOException { Map<String, List<Put>> putMap = createRsPutMap(htable, puts); for (List<Put> rsPuts: putMap.values()) { htable.put( rsPuts ); } htable.flushCommits(); }  static void bucketRsPut(HTable htable, List<Put> puts); static void bucketRsBatch(HTable htable, List<Row> rows);  }### Answer:
@Test public void testBucketPut() throws Exception { byte [] TABLE = Bytes.toBytes("testBucketPut"); HTable ht = TEST_UTIL.createTable(TABLE, FAMILY); ht.setAutoFlush( false ); List<Put> puts = new ArrayList<Put>(); puts.add( createPut("row1") ); puts.add( createPut("row2") ); puts.add( createPut("row3") ); puts.add( createPut("row4") ); HTableUtil.bucketRsPut( ht, puts ); Scan scan = new Scan(); scan.addColumn(FAMILY, QUALIFIER); int count = 0; for(Result result : ht.getScanner(scan)) { count++; } LOG.info("bucket put count=" + count); assertEquals(count, puts.size()); ht.close(); }