Java 类org.apache.hadoop.hbase.coprocessor.MultiRowMutationProtocol 实例源码

项目：LCIndex-HBase-0.94.16 文件：TestFromClientSide.java

@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)));
}

项目：IRIndex 文件：TestFromClientSide.java

@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)));
}

项目：HBase-Research 文件：TestFromClientSide.java

@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)));
}

项目：hbase-0.94.8-qod 文件：TestFromClientSide.java

@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)));
}

项目：hbase-0.94.8-qod 文件：TestFromClientSide.java

@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)));
}

项目：hindex 文件：TestFromClientSide.java

@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)));
}