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

x33g5p2x  于2022-01-19 转载在 其他  
字(7.9k)|赞(0)|评价(0)|浏览(119)

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

Get.setReplicaId介绍

暂无

代码示例

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

@Override
 protected void readAndCheck(AsyncTable<?> table, int replicaId) throws Exception {
  Get get = new Get(ROW).setConsistency(Consistency.TIMELINE);
  if (replicaId >= 0) {
   get.setReplicaId(replicaId);
  }
  assertArrayEquals(VALUE, table.get(get).get().getValue(FAMILY, QUALIFIER));
 }
}

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

this.setReplicaId(get.getReplicaId());
this.setConsistency(get.getConsistency());

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

protected Get createGet(long keyToRead) throws IOException {
 Get get = new Get(dataGenerator.getDeterministicUniqueKey(keyToRead));
 String cfsString = "";
 byte[][] columnFamilies = dataGenerator.getColumnFamilies();
 for (byte[] cf : columnFamilies) {
  get.addFamily(cf);
  if (verbose) {
   if (cfsString.length() > 0) {
    cfsString += ", ";
   }
   cfsString += "[" + Bytes.toStringBinary(cf) + "]";
  }
 }
 get = dataGenerator.beforeGet(keyToRead, get);
 if (regionReplicaId > 0) {
  get.setReplicaId(regionReplicaId);
  get.setConsistency(Consistency.TIMELINE);
 }
 if (verbose) {
  LOG.info("[" + readerId + "] " + "Querying key " + keyToRead + ", cfs " + cfsString);
 }
 return get;
}

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

public void verifyNumericRows(Table table, final byte[] f, int startRow, int endRow,
  int replicaId)
  throws IOException {
 for (int i = startRow; i < endRow; i++) {
  String failMsg = "Failed verification of row :" + i;
  byte[] data = Bytes.toBytes(String.valueOf(i));
  Get get = new Get(data);
  get.setReplicaId(replicaId);
  get.setConsistency(Consistency.TIMELINE);
  Result result = table.get(get);
  assertTrue(failMsg, result.containsColumn(f, null));
  assertEquals(failMsg, 1, result.getColumnCells(f, null).size());
  Cell cell = result.getColumnLatestCell(f, null);
  assertTrue(failMsg,
   Bytes.equals(data, 0, data.length, cell.getValueArray(), cell.getValueOffset(),
    cell.getValueLength()));
 }
}

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

/**
 * Tests the case where a newly created table with region replicas and no data, the secondary
 * region replicas are available to read immediately.
 */
@Test
public void testSecondaryRegionWithEmptyRegion() throws IOException {
 // Create a new table with region replication, don't put any data. Test that the secondary
 // region replica is available to read.
 try (Connection connection = ConnectionFactory.createConnection(HTU.getConfiguration());
   Table table = connection.getTable(htd.getTableName())) {
  Get get = new Get(row);
  get.setConsistency(Consistency.TIMELINE);
  get.setReplicaId(1);
  table.get(get); // this should not block
 }
}

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

@Test
public void testGetOnTargetRegionReplica() throws Exception {
 try {
  //load some data to primary
  HTU.loadNumericRows(table, f, 0, 1000);
  // assert that we can read back from primary
  Assert.assertEquals(1000, HTU.countRows(table));
  // flush so that region replica can read
  HRegion region = getRS().getRegionByEncodedName(hriPrimary.getEncodedName());
  region.flush(true);
  openRegion(HTU, getRS(), hriSecondary);
  // try directly Get against region replica
  byte[] row = Bytes.toBytes(String.valueOf(42));
  Get get = new Get(row);
  get.setConsistency(Consistency.TIMELINE);
  get.setReplicaId(1);
  Result result = table.get(get);
  Assert.assertArrayEquals(row, result.getValue(f, null));
 } finally {
  HTU.deleteNumericRows(table, HConstants.CATALOG_FAMILY, 0, 1000);
  closeRegion(HTU, getRS(), hriSecondary);
 }
}

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

Get get = new Get(splits[i]);
get.setConsistency(Consistency.TIMELINE);
get.setReplicaId(j);

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

.setAttribute("att_v0", Bytes.toBytes("att_v0"))
.setColumnFamilyTimeRange(Bytes.toBytes("cf"), 0, 123)
.setReplicaId(3)
.setACL("test_user", new Permission(Permission.Action.READ))
.setAuthorizations(new Authorizations("test_label"))

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

out.setReplicaId(in.getTargetReplicaId());

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

get.setACL("u", new Permission(Permission.Action.READ));
get.setConsistency(Consistency.TIMELINE);
get.setReplicaId(2);
get.setIsolationLevel(IsolationLevel.READ_UNCOMMITTED);
get.setCheckExistenceOnly(true);

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

this.setReplicaId(get.getReplicaId());
this.setConsistency(get.getConsistency());

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

.setAttribute("att_v0", Bytes.toBytes("att_v0"))
.setColumnFamilyTimeRange(Bytes.toBytes("cf"), 0, 123)
.setReplicaId(3)
.setACL("test_user", new Permission(Permission.Action.READ))
.setAuthorizations(new Authorizations("test_label"))

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

get.setACL("u", new Permission(Permission.Action.READ));
get.setConsistency(Consistency.TIMELINE);
get.setReplicaId(2);
get.setIsolationLevel(IsolationLevel.READ_UNCOMMITTED);
get.setCheckExistenceOnly(true);

代码示例来源：origin: harbby/presto-connectors

this.setReplicaId(get.getReplicaId());
this.setConsistency(get.getConsistency());

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

this.setReplicaId(get.getReplicaId());
this.setConsistency(get.getConsistency());

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

protected Get createGet(long keyToRead) throws IOException {
 Get get = new Get(dataGenerator.getDeterministicUniqueKey(keyToRead));
 String cfsString = "";
 byte[][] columnFamilies = dataGenerator.getColumnFamilies();
 for (byte[] cf : columnFamilies) {
  get.addFamily(cf);
  if (verbose) {
   if (cfsString.length() > 0) {
    cfsString += ", ";
   }
   cfsString += "[" + Bytes.toStringBinary(cf) + "]";
  }
 }
 get = dataGenerator.beforeGet(keyToRead, get);
 if (regionReplicaId > 0) {
  get.setReplicaId(regionReplicaId);
  get.setConsistency(Consistency.TIMELINE);
 }
 if (verbose) {
  LOG.info("[" + readerId + "] " + "Querying key " + keyToRead + ", cfs " + cfsString);
 }
 return get;
}

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

public void verifyNumericRows(Table table, final byte[] f, int startRow, int endRow,
  int replicaId)
  throws IOException {
 for (int i = startRow; i < endRow; i++) {
  String failMsg = "Failed verification of row :" + i;
  byte[] data = Bytes.toBytes(String.valueOf(i));
  Get get = new Get(data);
  get.setReplicaId(replicaId);
  get.setConsistency(Consistency.TIMELINE);
  Result result = table.get(get);
  assertTrue(failMsg, result.containsColumn(f, null));
  assertEquals(failMsg, 1, result.getColumnCells(f, null).size());
  Cell cell = result.getColumnLatestCell(f, null);
  assertTrue(failMsg,
   Bytes.equals(data, 0, data.length, cell.getValueArray(), cell.getValueOffset(),
    cell.getValueLength()));
 }
}

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

/**
 * Tests the case where a newly created table with region replicas and no data, the secondary
 * region replicas are available to read immediately.
 */
@Test
public void testSecondaryRegionWithEmptyRegion() throws IOException {
 // Create a new table with region replication, don't put any data. Test that the secondary
 // region replica is available to read.
 try (Connection connection = ConnectionFactory.createConnection(HTU.getConfiguration());
   Table table = connection.getTable(htd.getTableName())) {
  Get get = new Get(row);
  get.setConsistency(Consistency.TIMELINE);
  get.setReplicaId(1);
  table.get(get); // this should not block
 }
}

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

@Test
public void testGetOnTargetRegionReplica() throws Exception {
 try {
  //load some data to primary
  HTU.loadNumericRows(table, f, 0, 1000);
  // assert that we can read back from primary
  Assert.assertEquals(1000, HTU.countRows(table));
  // flush so that region replica can read
  HRegion region = getRS().getRegionByEncodedName(hriPrimary.getEncodedName());
  region.flush(true);
  openRegion(HTU, getRS(), hriSecondary);
  // try directly Get against region replica
  byte[] row = Bytes.toBytes(String.valueOf(42));
  Get get = new Get(row);
  get.setConsistency(Consistency.TIMELINE);
  get.setReplicaId(1);
  Result result = table.get(get);
  Assert.assertArrayEquals(row, result.getValue(f, null));
 } finally {
  HTU.deleteNumericRows(table, HConstants.CATALOG_FAMILY, 0, 1000);
  closeRegion(HTU, getRS(), hriSecondary);
 }
}

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

Get get = new Get(splits[i]);
get.setConsistency(Consistency.TIMELINE);
get.setReplicaId(j);

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

GET

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Get类方法

    • 蜀ICP备2022004421号-2 NULL123 https://www.null123.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com