org.apache.hadoop.hbase.client.Table.mutateRow()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(9.3k)|赞(0)|评价(0)|浏览(237)

本文整理了Java中org.apache.hadoop.hbase.client.Table.mutateRow()方法的一些代码示例，展示了Table.mutateRow()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Table.mutateRow()方法的具体详情如下：
包路径：org.apache.hadoop.hbase.client.Table
类名称：Table
方法名：mutateRow

Table.mutateRow介绍

[英]Performs multiple mutations atomically on a single row. Currently Put and Delete are supported.
[中]在一行上以原子方式执行多个突变。目前支持Put和Delete。

代码示例

代码示例来源：origin: apache/hbase

  1. @Override
  2. public void mutateRow(ByteBuffer table, TRowMutations rowMutations) throws TIOError, TException {
  3.  checkReadOnlyMode();
  4.  Table htable = getTable(table);
  5.  try {
  6.   htable.mutateRow(rowMutationsFromThrift(rowMutations));
  7.  } catch (IOException e) {
  8.   throw getTIOError(e);
  9.  } finally {
  10.   closeTable(htable);
  11.  }
  12. }

代码示例来源：origin: apache/hbase

  1. /**
  2.  * Reset the split parent region info in meta table
  3.  */
  4. private void resetSplitParent(HbckInfo hi) throws IOException {
  5.  RowMutations mutations = new RowMutations(hi.metaEntry.getRegionName());
  6.  Delete d = new Delete(hi.metaEntry.getRegionName());
  7.  d.addColumn(HConstants.CATALOG_FAMILY, HConstants.SPLITA_QUALIFIER);
  8.  d.addColumn(HConstants.CATALOG_FAMILY, HConstants.SPLITB_QUALIFIER);
  9.  mutations.add(d);
  10.  RegionInfo hri = RegionInfoBuilder.newBuilder(hi.metaEntry)
  11.    .setOffline(false)
  12.    .setSplit(false)
  13.    .build();
  14.  Put p = MetaTableAccessor.makePutFromRegionInfo(hri, EnvironmentEdgeManager.currentTime());
  15.  mutations.add(p);
  16.  meta.mutateRow(mutations);
  17.  LOG.info("Reset split parent " + hi.metaEntry.getRegionNameAsString() + " in META" );
  18. }

代码示例来源：origin: apache/hbase

  1. @Test
  2. public void testRowMutationsWithPreBatchMutate() throws Exception {
  3.  final TableName tableName = TableName.valueOf(name.getMethodName());
  4.  testPreBatchMutate(tableName, () -> {
  5.   try {
  6.    RowMutations rm = new RowMutations(ROW, 1);
  7.    Table t = TEST_UTIL.getConnection().getTable(tableName);
  8.    Put put = new Put(ROW);
  9.    put.addColumn(FAMILY, QUALIFIER, VALUE);
  10.    rm.add(put);
  11.    t.mutateRow(rm);
  12.   } catch (IOException ex) {
  13.    throw new RuntimeException(ex);
  14.   }
  15.  });
  16. }

代码示例来源：origin: apache/phoenix

  1. @Override
  2. public void mutateRow(RowMutations rm) throws IOException {
  3.   delegate.mutateRow(rm);
  4. }

代码示例来源：origin: apache/hbase

  1. p.addColumn(FAMILY, QUALIFIERS[0], VALUE);
  2. arm.add(p);
  3. t.mutateRow(arm);
  4. arm.add(d);
  5. t.mutateRow(arm);
  6. r = t.get(g);
  7. assertEquals(0, Bytes.compareTo(VALUE, r.getValue(FAMILY, QUALIFIERS[1])));
  8.  p.addColumn(new byte[]{'b', 'o', 'g', 'u', 's'}, QUALIFIERS[0], VALUE);
  9.  arm.add(p);
  10.  t.mutateRow(arm);
  11.  fail("Expected NoSuchColumnFamilyException");
  12. } catch(RetriesExhaustedWithDetailsException e) {

代码示例来源：origin: apache/hbase

  1. Arrays.asList(new Put(Bytes.toBytes("row")).addColumn(CF, CQ, Bytes.toBytes("row")),
  2.    new Put(Bytes.toBytes("row1")).addColumn(CF, CQ, Bytes.toBytes("row1")))));
  3. assertDisallow(table, t -> t.mutateRow(new RowMutations(Bytes.toBytes("row"))
  4.   .add((Mutation) new Put(Bytes.toBytes("row")).addColumn(CF, CQ, Bytes.toBytes("row")))));

代码示例来源：origin: apache/hbase

  1. p1.setDurability(Durability.SYNC_WAL);
  2. rm.add(p1);
  3. hTable.mutateRow(rm);

代码示例来源：origin: apache/hbase

  1. @Test
  2. public void testFlushedFileWithVisibilityTags() throws Exception {
  3.  final byte[] qual2 = Bytes.toBytes("qual2");
  4.  TableName tableName = TableName.valueOf(TEST_NAME.getMethodName());
  5.  HTableDescriptor desc = new HTableDescriptor(tableName);
  6.  HColumnDescriptor col = new HColumnDescriptor(fam);
  7.  desc.addFamily(col);
  8.  TEST_UTIL.getAdmin().createTable(desc);
  9.  try (Table table = TEST_UTIL.getConnection().getTable(tableName)) {
  10.   Put p1 = new Put(row1);
  11.   p1.addColumn(fam, qual, value);
  12.   p1.setCellVisibility(new CellVisibility(CONFIDENTIAL));
  13.   Put p2 = new Put(row1);
  14.   p2.addColumn(fam, qual2, value);
  15.   p2.setCellVisibility(new CellVisibility(SECRET));
  16.   RowMutations rm = new RowMutations(row1);
  17.   rm.add(p1);
  18.   rm.add(p2);
  19.   table.mutateRow(rm);
  20.  }
  21.  TEST_UTIL.getAdmin().flush(tableName);
  22.  List<HRegion> regions = TEST_UTIL.getHBaseCluster().getRegions(tableName);
  23.  HStore store = regions.get(0).getStore(fam);
  24.  Collection<HStoreFile> storefiles = store.getStorefiles();
  25.  assertTrue(storefiles.size() > 0);
  26.  for (HStoreFile storeFile : storefiles) {
  27.   assertTrue(storeFile.getReader().getHFileReader().getFileContext().isIncludesTags());
  28.  }
  29. }

代码示例来源：origin: apache/hbase

  1. @Test
  2.  public void testMutateRowStats() throws IOException {
  3.   Configuration conf = UTIL.getConfiguration();
  4.   ClusterConnection conn = (ClusterConnection) ConnectionFactory.createConnection(conf);
  5.   Table table = conn.getTable(tableName);
  6.   HRegionServer rs = UTIL.getHBaseCluster().getRegionServer(0);
  7.   Region region = rs.getRegions(tableName).get(0);
  9.   RowMutations mutations = new RowMutations(Bytes.toBytes("row"));
  10.   Put p = new Put(Bytes.toBytes("row"));
  11.   p.addColumn(family, qualifier, Bytes.toBytes("value2"));
  12.   mutations.add(p);
  13.   table.mutateRow(mutations);
  15.   ServerStatisticTracker stats = conn.getStatisticsTracker();
  16.   assertNotNull( "No stats configured for the client!", stats);
  17.   // get the names so we can query the stats
  18.   ServerName server = rs.getServerName();
  19.   byte[] regionName = region.getRegionInfo().getRegionName();
  21.   // check to see we found some load on the memstore
  22.   ServerStatistics serverStats = stats.getServerStatsForTesting(server);
  23.   ServerStatistics.RegionStatistics regionStats = serverStats.getStatsForRegion(regionName);
  25.   assertNotNull(regionStats);
  26.   assertTrue(regionStats.getMemStoreLoadPercent() > 0);
  27.   }
  28. }

代码示例来源：origin: apache/hbase

  1. @Test
  2. public void testMutateRow() throws Exception {
  3.  final byte[] qual2 = Bytes.toBytes("qual2");
  4.  TableName tableName = TableName.valueOf(TEST_NAME.getMethodName());
  5.  HTableDescriptor desc = new HTableDescriptor(tableName);
  6.  HColumnDescriptor col = new HColumnDescriptor(fam);
  7.  desc.addFamily(col);
  8.  TEST_UTIL.getAdmin().createTable(desc);
  9.  try (Table table = TEST_UTIL.getConnection().getTable(tableName)){
  10.   Put p1 = new Put(row1);
  11.   p1.addColumn(fam, qual, value);
  12.   p1.setCellVisibility(new CellVisibility(CONFIDENTIAL));
  13.   Put p2 = new Put(row1);
  14.   p2.addColumn(fam, qual2, value);
  15.   p2.setCellVisibility(new CellVisibility(SECRET));
  16.   RowMutations rm = new RowMutations(row1);
  17.   rm.add(p1);
  18.   rm.add(p2);
  19.   table.mutateRow(rm);
  20.   Get get = new Get(row1);
  21.   get.setAuthorizations(new Authorizations(CONFIDENTIAL));
  22.   Result result = table.get(get);
  23.   assertTrue(result.containsColumn(fam, qual));
  24.   assertFalse(result.containsColumn(fam, qual2));
  25.   get.setAuthorizations(new Authorizations(SECRET));
  26.   result = table.get(get);
  27.   assertFalse(result.containsColumn(fam, qual));
  28.   assertTrue(result.containsColumn(fam, qual2));
  29.  }
  30. }

代码示例来源：origin: apache/hbase

  1. @Test
  2. public void testRowMutation() throws IOException {
  3.  final TableName tableName = TableName.valueOf(TEST_TABLE.getNameAsString() + "." + name.getMethodName());
  4.  Table table = util.createTable(tableName, new byte[][] { A, B, C });
  5.  try {
  6.   verifyMethodResult(SimpleRegionObserver.class,
  7.    new String[] { "hadPreGet", "hadPostGet", "hadPrePut", "hadPostPut", "hadDeleted" },
  8.    tableName, new Boolean[] { false, false, false, false, false });
  9.   Put put = new Put(ROW);
  10.   put.addColumn(A, A, A);
  11.   put.addColumn(B, B, B);
  12.   put.addColumn(C, C, C);
  13.   Delete delete = new Delete(ROW);
  14.   delete.addColumn(A, A);
  15.   delete.addColumn(B, B);
  16.   delete.addColumn(C, C);
  17.   RowMutations arm = new RowMutations(ROW);
  18.   arm.add(put);
  19.   arm.add(delete);
  20.   table.mutateRow(arm);
  21.   verifyMethodResult(SimpleRegionObserver.class,
  22.    new String[] { "hadPreGet", "hadPostGet", "hadPrePut", "hadPostPut", "hadDeleted" },
  23.    tableName, new Boolean[] { false, false, true, true, true });
  24.  } finally {
  25.   util.deleteTable(tableName);
  26.   table.close();
  27.  }
  28. }

代码示例来源：origin: apache/hbase

  1. table.increment(increment);
  2.  table.delete(delete);
  3.  table.mutateRow(mutations);
  4. } catch (IOException ex) {

代码示例来源：origin: larsgeorge/hbase-book

  1. mutations.add(delete);
  2. table.mutateRow(mutations);

代码示例来源：origin: larsgeorge/hbase-book

  1. Bytes.toBytes("val10"));
  2. mutations.add(put);
  3. table.mutateRow(mutations);
  4. printStatistics(true, true);

代码示例来源：origin: org.apache.phoenix/phoenix-core

  1. @Override
  2. public void mutateRow(RowMutations rm) throws IOException {
  3.   delegate.mutateRow(rm);
  4. }

代码示例来源：origin: com.aliyun.phoenix/ali-phoenix-core

  1. @Override
  2. public void mutateRow(RowMutations rm) throws IOException {
  3.   delegate.mutateRow(rm);
  4. }

代码示例来源：origin: org.apache.hbase/hbase-thrift

  1. @Override
  2. public void mutateRow(ByteBuffer table, TRowMutations rowMutations) throws TIOError, TException {
  3.  checkReadOnlyMode();
  4.  Table htable = getTable(table);
  5.  try {
  6.   htable.mutateRow(rowMutationsFromThrift(rowMutations));
  7.  } catch (IOException e) {
  8.   throw getTIOError(e);
  9.  } finally {
  10.   closeTable(htable);
  11.  }
  12. }

代码示例来源：origin: org.apache.tephra/tephra-hbase-compat-1.1

  1. @Override
  2. public void mutateRow(RowMutations rm) throws IOException {
  3.  if (tx == null) {
  4.   throw new IOException("Transaction not started");
  5.  }
  6.  RowMutations transactionalMutations = new RowMutations();
  7.  for (Mutation mutation : rm.getMutations()) {
  8.   if (mutation instanceof Put) {
  9.    transactionalMutations.add(transactionalizeAction((Put) mutation));
  10.   } else if (mutation instanceof Delete) {
  11.    transactionalMutations.add(transactionalizeAction((Delete) mutation));
  12.   }
  13.  }
  14.  hTable.mutateRow(transactionalMutations);
  15. }

代码示例来源：origin: com.aliyun.hbase/alihbase-thrift

  1. @Override
  2. public void mutateRow(ByteBuffer table, TRowMutations rowMutations) throws TIOError, TException {
  3.  checkReadOnlyMode();
  4.  Table htable = getTable(table);
  5.  try {
  6.   htable.mutateRow(rowMutationsFromThrift(rowMutations));
  7.  } catch (IOException e) {
  8.   throw getTIOError(e);
  9.  } finally {
  10.   closeTable(htable);
  11.  }
  12. }

代码示例来源：origin: org.apache.hbase/hbase-server

  1. @Test
  2. public void testRowMutationsWithPreBatchMutate() throws Exception {
  3.  final TableName tableName = TableName.valueOf(name.getMethodName());
  4.  testPreBatchMutate(tableName, () -> {
  5.   try {
  6.    RowMutations rm = new RowMutations(ROW, 1);
  7.    Table t = TEST_UTIL.getConnection().getTable(tableName);
  8.    Put put = new Put(ROW);
  9.    put.addColumn(FAMILY, QUALIFIER, VALUE);
  10.    rm.add(put);
  11.    t.mutateRow(rm);
  12.   } catch (IOException ex) {
  13.    throw new RuntimeException(ex);
  14.   }
  15.  });
  16. }

内容来源于网络，如有侵权，请联系作者删除！

Table

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com