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

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

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

Table.delete介绍

[英]Deletes the specified cells/rows in bulk.
[中]批量删除指定的单元格/行。

代码示例

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

  1. public void deleteBulkLoadedRows(List<byte[]> rows) throws IOException {
  2.  try (Table table = connection.getTable(bulkLoadTableName)) {
  3.   List<Delete> lstDels = new ArrayList<>();
  4.   for (byte[] row : rows) {
  5.    Delete del = new Delete(row);
  6.    lstDels.add(del);
  7.    LOG.debug("orig deleting the row: " + Bytes.toString(row));
  8.   }
  9.   table.delete(lstDels);
  10.   LOG.debug("deleted " + rows.size() + " original bulkload rows");
  11.  }
  12. }

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

  1. public void finishDeleteOperation() throws IOException {
  2.  LOG.trace("Finsih delete operation for backup ids");
  3.  Delete delete = createDeleteForBackupDeleteOperation();
  4.  try (Table table = connection.getTable(tableName)) {
  5.   table.delete(delete);
  6.  }
  7. }

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

  1. @Override
  2.  protected void execute(Table table) throws IOException {
  3.   table.delete(new Delete(FAM_NAM));
  4.  }
  5. }

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

  1. @Override
  2.  public Object run() throws Exception {
  3.   Delete d = new Delete(TEST_ROW);
  4.   d.addFamily(TEST_FAMILY);
  5.   try(Connection conn = ConnectionFactory.createConnection(conf);
  6.     Table t = conn.getTable(TEST_TABLE)) {
  7.    t.delete(d);
  8.   }
  9.   return null;
  10.  }
  11. };

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

  1. @Test
  2. public void testMultiPut() throws Exception {
  3.  List<Put> puts = IntStream.range(0, 10)
  4.   .mapToObj(i -> new Put(ROW).addColumn(FAMILY, Bytes.toBytes(i), VALUE))
  5.   .collect(Collectors.toList());
  6.  table.put(puts);
  7.  assertResult(table.get(new Get(ROW)), VALUE);
  8.  assertObserverHasExecuted();
  9.  List<Delete> deletes = IntStream.range(0, 10)
  10.   .mapToObj(i -> new Delete(ROW).addColumn(FAMILY, Bytes.toBytes(i)))
  11.   .collect(Collectors.toList());
  12.  table.delete(deletes);
  13.  assertTrue(table.get(new Get(ROW)).isEmpty());
  14.  assertObserverHasExecuted();
  15. }

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

  1. @Test(expected = DoNotRetryIOException.class)
  2. public void testDeleteWithDoNotRetryIOException() throws Exception {
  3.  tableDoNotRetry.delete(new Delete(Bytes.toBytes("row")).addColumn(CF, CQ));
  4. }

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

  1. @Override
  2.  public Object run() throws Exception {
  3.   Delete d = new Delete(TEST_ROW);
  4.   d.addColumn(family1, qualifier);
  5.   // d.deleteFamily(family1);
  6.   try (Connection conn = ConnectionFactory.createConnection(conf);
  7.     Table t = conn.getTable(tableName)) {
  8.    t.delete(d);
  9.   }
  10.   return null;
  11.  }
  12. };

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

  1. @Test
  2. public void testFlushPrimary() throws Exception {
  3.  openRegion(hriSecondary);
  4.  try {
  5.   flushRegion(hriPrimary);
  6.   Put p = new Put(row);
  7.   p.addColumn(f, row, row);
  8.   table.put(p);
  9.   flushRegion(hriPrimary);
  10.  } finally {
  11.   Delete d = new Delete(row);
  12.   table.delete(d);
  13.   closeRegion(hriSecondary);
  14.  }
  15. }

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

  1. @Test(expected = RetriesExhaustedException.class)
  2. public void testDeleteWithIOException() throws Exception {
  3.  tableRetry.delete(new Delete(Bytes.toBytes("row")).addColumn(CF, CQ));
  4. }

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

  1. public void deleteNamespace(String namespaceName) throws IOException {
  2.  Delete d = new Delete(Bytes.toBytes(namespaceName));
  3.  try (Table table = masterServices.getConnection().getTable(TableName.META_TABLE_NAME)) {
  4.   table.delete(d);
  5.  }
  6.  cache.remove(namespaceName);
  7. }

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

  1. @Override
  2.  public Object run() throws Exception {
  3.   Delete d = new Delete(TEST_ROW);
  4.   d.addFamily(family1);
  5.   try (Connection conn = ConnectionFactory.createConnection(conf);
  6.     Table t = conn.getTable(tableName)) {
  7.    t.delete(d);
  8.   }
  9.   return null;
  10.  }
  11. };

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

  1. @Test
  2. public void testDeleteFamily() throws Exception {
  3.  createTable(TestDeleteFamilyCoprocessor.class.getName());
  4.  try (Table t = util.getConnection().getTable(tableName)) {
  5.   t.put(Lists.newArrayList(
  6.    new Put(row1).addColumn(test, dummy, dummy),
  7.    new Put(row2).addColumn(test, dummy, dummy),
  8.    new Put(row3).addColumn(test, dummy, dummy)
  9.     ));
  10.   assertRowCount(t, 3);
  11.   t.delete(new Delete(test).addFamily(test)); // delete non-existing row
  12.   assertRowCount(t, 1);
  13.  }
  14. }

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

  1. @Test
  2. public void testIncrementWithDeletes() throws Exception {
  3.  LOG.info("Starting " + this.name.getMethodName());
  4.  final TableName TABLENAME =
  5.    TableName.valueOf(filterStringSoTableNameSafe(this.name.getMethodName()));
  6.  Table ht = TEST_UTIL.createTable(TABLENAME, FAMILY);
  7.  final byte[] COLUMN = Bytes.toBytes("column");
  8.  ht.incrementColumnValue(ROW, FAMILY, COLUMN, 5);
  9.  TEST_UTIL.flush(TABLENAME);
  10.  Delete del = new Delete(ROW);
  11.  ht.delete(del);
  12.  ht.incrementColumnValue(ROW, FAMILY, COLUMN, 5);
  13.  Get get = new Get(ROW);
  14.  Result r = ht.get(get);
  15.  assertEquals(1, r.size());
  16.  assertEquals(5, Bytes.toLong(r.getValue(FAMILY, COLUMN)));
  17. }

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

  1. private void clearCatalogFamily(RegionInfo region) throws IOException {
  2.  try (Table table = UTIL.getConnection().getTable(TableName.META_TABLE_NAME)) {
  3.   table.delete(new Delete(region.getRegionName()).addFamily(HConstants.CATALOG_FAMILY));
  4.  }
  5. }

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

  1. @Override
  2.  public Object run() throws Exception {
  3.   Delete d = new Delete(TEST_ROW);
  4.   d.addFamily(family2);
  5.   try (Connection conn = ConnectionFactory.createConnection(conf);
  6.     Table t = conn.getTable(tableName)) {
  7.    t.delete(d);
  8.   }
  9.   return null;
  10.  }
  11. };

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

  1. @Test
  2. public void testDeleteCell() throws Exception {
  3.  createTable(TestDeleteCellCoprocessor.class.getName());
  4.  try (Table t = util.getConnection().getTable(tableName)) {
  5.   t.put(Lists.newArrayList(
  6.    new Put(row1).addColumn(test, dummy, dummy),
  7.    new Put(row2).addColumn(test, dummy, dummy),
  8.    new Put(row3).addColumn(test, dummy, dummy)
  9.     ));
  10.   assertRowCount(t, 3);
  11.   t.delete(new Delete(test).addColumn(test, dummy)); // delete non-existing row
  12.   assertRowCount(t, 1);
  13.  }
  14. }

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

  1. @Override
  2.  public Void run() throws Exception {
  3.   try (Connection connection = ConnectionFactory.createConnection(conf);
  4.    Table table = connection.getTable(tableName)) {
  5.    Delete d = new Delete(row1);
  6.    d.addFamilyVersion(fam, 126L);
  7.    table.delete(d);
  8.   } catch (Throwable t) {
  9.    throw new IOException(t);
  10.   }
  11.   return null;
  12.  }
  13. };

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

  1. @Test
  2. public void testDeleteRow() throws Exception {
  3.  createTable(TestDeleteRowCoprocessor.class.getName());
  4.  try (Table t = util.getConnection().getTable(tableName)) {
  5.   t.put(Lists.newArrayList(
  6.    new Put(row1).addColumn(test, dummy, dummy),
  7.    new Put(row2).addColumn(test, dummy, dummy),
  8.    new Put(row3).addColumn(test, dummy, dummy)
  9.     ));
  10.   assertRowCount(t, 3);
  11.   t.delete(new Delete(test).addColumn(test, dummy)); // delete non-existing row
  12.   assertRowCount(t, 1);
  13.  }
  14. }

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

  1. @Override
  2.  public Void run() throws Exception {
  3.   try (Connection connection = ConnectionFactory.createConnection(conf);
  4.    Table table = connection.getTable(tableName)) {
  5.    Delete d = new Delete(row1);
  6.    d.addColumn(fam, qual, 125L);
  7.    table.delete(d);
  8.   } catch (Throwable t) {
  9.    throw new IOException(t);
  10.   }
  11.   return null;
  12.  }
  13. };

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

  1. @Test
  2. public void testFlushSecondary() throws Exception {
  3.  openRegion(hriSecondary);
  4.  try {
  5.   flushRegion(hriSecondary);
  6.   Put p = new Put(row);
  7.   p.addColumn(f, row, row);
  8.   table.put(p);
  9.   flushRegion(hriSecondary);
  10.  } catch (TableNotFoundException expected) {
  11.  } finally {
  12.   Delete d = new Delete(row);
  13.   table.delete(d);
  14.   closeRegion(hriSecondary);
  15.  }
  16. }

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

Table

相关文章

    查看更多

    热门标签

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

    最新文章

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