@Test public void testMultiRowMutation() throws Exception { LOG.info("Starting testMultiRowMutation"); final byte [] TABLENAME = Bytes.toBytes("testMultiRowMutation"); final byte [] ROW1 = Bytes.toBytes("testRow1"); HTable t = TEST_UTIL.createTable(TABLENAME, FAMILY); List<Mutation> mrm = new ArrayList<Mutation>(); Put p = new Put(ROW); p.add(FAMILY, QUALIFIER, VALUE); mrm.add(p); p = new Put(ROW1); p.add(FAMILY, QUALIFIER, VALUE); mrm.add(p); MultiRowMutationProtocol mr = t.coprocessorProxy( MultiRowMutationProtocol.class, ROW); mr.mutateRows(mrm); Get g = new Get(ROW); Result r = t.get(g); assertEquals(0, Bytes.compareTo(VALUE, r.getValue(FAMILY, QUALIFIER))); g = new Get(ROW1); r = t.get(g); assertEquals(0, Bytes.compareTo(VALUE, r.getValue(FAMILY, QUALIFIER))); }