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

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

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

Table.batchCoprocessorService介绍

[英]Creates an instance of the given com.facebook.presto.hbase.$internal.com.google.protobuf.Service subclass for each table region spanning the range from the startKey row to endKey row (inclusive), all the invocations to the same region server will be batched into one call. The coprocessor service is invoked according to the service instance, method name and parameters.
[中]创建给定com的实例。脸谱网。急板地。hbase$内部的通用域名格式。谷歌。protobuf。服务子类对于从startKey行到endKey行（包括在内）范围内的每个表区域，对同一区域服务器的所有调用都将批处理为一个调用。协处理器服务根据服务实例、方法名称和参数进行调用。

代码示例

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

  1. private Map<byte[], SumResponse> sum(final Table table, final byte[] family,
  2.   final byte[] qualifier, final byte[] start, final byte[] end) throws ServiceException,
  3.   Throwable {
  4.  ColumnAggregationProtos.SumRequest.Builder builder = ColumnAggregationProtos.SumRequest
  5.    .newBuilder();
  6.  builder.setFamily(ByteString.copyFrom(family));
  7.  if (qualifier != null && qualifier.length > 0) {
  8.   builder.setQualifier(ByteString.copyFrom(qualifier));
  9.  }
  10.  return table.batchCoprocessorService(
  11.    ColumnAggregationProtos.ColumnAggregationService.getDescriptor().findMethodByName("sum"),
  12.    builder.build(), start, end, ColumnAggregationProtos.SumResponse.getDefaultInstance());
  13. }

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

  1. @Override
  2. public <R extends Message> Map<byte[], R> batchCoprocessorService(
  3.     MethodDescriptor methodDescriptor, Message request, byte[] startKey, byte[] endKey,
  4.     R responsePrototype) throws ServiceException, Throwable {
  5.   return delegate.batchCoprocessorService(methodDescriptor, request, startKey, endKey, responsePrototype);
  6. }

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

  1. @Override
  2. public <R extends Message> void batchCoprocessorService(MethodDescriptor methodDescriptor,
  3.     Message request, byte[] startKey, byte[] endKey, R responsePrototype,
  4.     Callback<R> callback) throws ServiceException, Throwable {
  5.   delegate.batchCoprocessorService(methodDescriptor, request, startKey, endKey, responsePrototype);
  6. }

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

  1. @Test
  2. public void testAggregationNullResponse() throws Throwable {
  3.  Table table = util.getConnection().getTable(TEST_TABLE);
  4.  ColumnAggregationNullResponseSumRequest.Builder builder =
  5.    ColumnAggregationNullResponseSumRequest
  6.    .newBuilder();
  7.  builder.setFamily(ByteString.copyFrom(TEST_FAMILY));
  8.  if (TEST_QUALIFIER != null && TEST_QUALIFIER.length > 0) {
  9.   builder.setQualifier(ByteString.copyFrom(TEST_QUALIFIER));
  10.  }
  11.  Map<byte[], ColumnAggregationNullResponseSumResponse> results =
  12.    table.batchCoprocessorService(
  13.      ColumnAggregationServiceNullResponse.getDescriptor().findMethodByName("sum"),
  14.      builder.build(), ROWS[0], ROWS[ROWS.length - 1],
  15.      ColumnAggregationNullResponseSumResponse.getDefaultInstance());
  16.  int sumResult = 0;
  17.  int expectedResult = 0;
  18.  for (Map.Entry<byte[], ColumnAggregationNullResponseSumResponse> e :
  19.    results.entrySet()) {
  20.   LOG.info("Got value " + e.getValue().getSum() + " for region "
  21.     + Bytes.toStringBinary(e.getKey()));
  22.   sumResult += e.getValue().getSum();
  23.  }
  24.  for (int i = 0; i < rowSeperator2; i++) {
  25.   expectedResult += i;
  26.  }
  27.  assertEquals("Invalid result", expectedResult, sumResult);
  28.  table.close();
  29. }

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

  1. table.batchCoprocessorService(
  2.   ColumnAggregationWithErrorsProtos.ColumnAggregationServiceWithErrors.getDescriptor()
  3.     .findMethodByName("sum"),

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

  1. @Test
  2.  public void testCoprocessorServiceLoadedByMaster() throws Throwable {
  3.   TEST_UTIL.getAdmin().coprocessorService().callBlockingMethod(
  4.       DummyCoprocessorService.getDescriptor().findMethodByName("dummyCall"), null,
  5.       DummyRequest.newBuilder().setValue(MASTER).build(), DummyResponse.getDefaultInstance());
  6.   assertEquals(MASTER, DummyCoprocessorService.numMaster);
  8.   TEST_UTIL.getAdmin().coprocessorService(
  9.     TEST_UTIL.getHBaseCluster().getRegionServer(0).getServerName()).callBlockingMethod(
  10.       DummyCoprocessorService.getDescriptor().findMethodByName("dummyCall"), null,
  11.       DummyRequest.newBuilder().setValue(REGIONSERVER).build(),
  12.       DummyResponse.getDefaultInstance());
  13.   assertEquals(REGIONSERVER, DummyCoprocessorService.numRegionServer);
  15.   TEST_UTIL.getConnection().getTable(TableName.valueOf("hbase:meta")).batchCoprocessorService(
  16.     DummyCoprocessorService.getDescriptor().findMethodByName("dummyCall"),
  17.     DummyRequest.newBuilder().setValue(REGION).build(), Bytes.toBytes(""), Bytes.toBytes(""),
  18.     DummyResponse.getDefaultInstance());
  19.   assertEquals(REGION, DummyCoprocessorService.numRegion);
  20.  }
  21. }

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

  1. Map<byte[], CountResponse> results = /*[*/table.batchCoprocessorService(
  2.  RowCountService.getDescriptor().findMethodByName("getRowCount"),
  3.  request, HConstants.EMPTY_START_ROW, HConstants.EMPTY_END_ROW,

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

  1. @Override
  2. public <R extends Message> Map<byte[], R> batchCoprocessorService(
  3.     MethodDescriptor methodDescriptor, Message request, byte[] startKey, byte[] endKey,
  4.     R responsePrototype) throws ServiceException, Throwable {
  5.   return delegate.batchCoprocessorService(methodDescriptor, request, startKey, endKey, responsePrototype);
  6. }

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

  1. @Override
  2. public <R extends Message> void batchCoprocessorService(MethodDescriptor methodDescriptor,
  3.     Message request, byte[] startKey, byte[] endKey, R responsePrototype,
  4.     Callback<R> callback) throws ServiceException, Throwable {
  5.   delegate.batchCoprocessorService(methodDescriptor, request, startKey, endKey, responsePrototype);
  6. }

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

  1. @Override
  2. public <R extends Message> Map<byte[], R> batchCoprocessorService(
  3.   MethodDescriptor methodDescriptor, Message request, byte[] startKey, byte[] endKey,
  4.   R responsePrototype) throws ServiceException, Throwable {
  5.  return hTable.batchCoprocessorService(methodDescriptor, request, startKey, endKey, responsePrototype);
  6. }

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

  1. @Override
  2. public <R extends Message> Map<byte[], R> batchCoprocessorService(
  3.     MethodDescriptor methodDescriptor, Message request, byte[] startKey, byte[] endKey,
  4.     R responsePrototype) throws ServiceException, Throwable {
  5.   return delegate.batchCoprocessorService(methodDescriptor, request, startKey, endKey, responsePrototype);
  6. }

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

  1. @Override
  2. public <R extends Message> void batchCoprocessorService(MethodDescriptor methodDescriptor,
  3.     Message request, byte[] startKey, byte[] endKey, R responsePrototype,
  4.     Callback<R> callback) throws ServiceException, Throwable {
  5.   delegate.batchCoprocessorService(methodDescriptor, request, startKey, endKey, responsePrototype);
  6. }

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

  1. @Override
  2. public <R extends Message> void batchCoprocessorService(MethodDescriptor methodDescriptor,
  3.   Message request, byte[] startKey, byte[] endKey, R responsePrototype, Callback<R> callback)
  4.   throws ServiceException, Throwable {
  5.  hTable.batchCoprocessorService(methodDescriptor, request, startKey, endKey, responsePrototype, callback);
  6. }

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

  1. private Map<byte[], SumResponse> sum(final Table table, final byte[] family,
  2.   final byte[] qualifier, final byte[] start, final byte[] end) throws ServiceException,
  3.   Throwable {
  4.  ColumnAggregationProtos.SumRequest.Builder builder = ColumnAggregationProtos.SumRequest
  5.    .newBuilder();
  6.  builder.setFamily(ByteString.copyFrom(family));
  7.  if (qualifier != null && qualifier.length > 0) {
  8.   builder.setQualifier(ByteString.copyFrom(qualifier));
  9.  }
  10.  return table.batchCoprocessorService(
  11.    ColumnAggregationProtos.ColumnAggregationService.getDescriptor().findMethodByName("sum"),
  12.    builder.build(), start, end, ColumnAggregationProtos.SumResponse.getDefaultInstance());
  13. }

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

  1. private Map<byte[], SumResponse> sum(final Table table, final byte[] family,
  2.   final byte[] qualifier, final byte[] start, final byte[] end) throws ServiceException,
  3.   Throwable {
  4.  ColumnAggregationProtos.SumRequest.Builder builder = ColumnAggregationProtos.SumRequest
  5.    .newBuilder();
  6.  builder.setFamily(ByteString.copyFrom(family));
  7.  if (qualifier != null && qualifier.length > 0) {
  8.   builder.setQualifier(ByteString.copyFrom(qualifier));
  9.  }
  10.  return table.batchCoprocessorService(
  11.    ColumnAggregationProtos.ColumnAggregationService.getDescriptor().findMethodByName("sum"),
  12.    builder.build(), start, end, ColumnAggregationProtos.SumResponse.getDefaultInstance());
  13. }

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

  1. @Test
  2. public void testAggregationNullResponse() throws Throwable {
  3.  Table table = util.getConnection().getTable(TEST_TABLE);
  4.  ColumnAggregationNullResponseSumRequest.Builder builder =
  5.    ColumnAggregationNullResponseSumRequest
  6.    .newBuilder();
  7.  builder.setFamily(ByteString.copyFrom(TEST_FAMILY));
  8.  if (TEST_QUALIFIER != null && TEST_QUALIFIER.length > 0) {
  9.   builder.setQualifier(ByteString.copyFrom(TEST_QUALIFIER));
  10.  }
  11.  Map<byte[], ColumnAggregationNullResponseSumResponse> results =
  12.    table.batchCoprocessorService(
  13.      ColumnAggregationServiceNullResponse.getDescriptor().findMethodByName("sum"),
  14.      builder.build(), ROWS[0], ROWS[ROWS.length - 1],
  15.      ColumnAggregationNullResponseSumResponse.getDefaultInstance());
  16.  int sumResult = 0;
  17.  int expectedResult = 0;
  18.  for (Map.Entry<byte[], ColumnAggregationNullResponseSumResponse> e :
  19.    results.entrySet()) {
  20.   LOG.info("Got value " + e.getValue().getSum() + " for region "
  21.     + Bytes.toStringBinary(e.getKey()));
  22.   sumResult += e.getValue().getSum();
  23.  }
  24.  for (int i = 0; i < rowSeperator2; i++) {
  25.   expectedResult += i;
  26.  }
  27.  assertEquals("Invalid result", expectedResult, sumResult);
  28.  table.close();
  29. }

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

  1. table.batchCoprocessorService(
  2.   ColumnAggregationWithErrorsProtos.ColumnAggregationServiceWithErrors.getDescriptor()
  3.     .findMethodByName("sum"),

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

  1. @Test
  2. public void testAggregationNullResponse() throws Throwable {
  3.  Table table = util.getConnection().getTable(TEST_TABLE);
  4.  ColumnAggregationNullResponseSumRequest.Builder builder =
  5.    ColumnAggregationNullResponseSumRequest
  6.    .newBuilder();
  7.  builder.setFamily(ByteString.copyFrom(TEST_FAMILY));
  8.  if (TEST_QUALIFIER != null && TEST_QUALIFIER.length > 0) {
  9.   builder.setQualifier(ByteString.copyFrom(TEST_QUALIFIER));
  10.  }
  11.  Map<byte[], ColumnAggregationNullResponseSumResponse> results =
  12.    table.batchCoprocessorService(
  13.      ColumnAggregationServiceNullResponse.getDescriptor().findMethodByName("sum"),
  14.      builder.build(), ROWS[0], ROWS[ROWS.length - 1],
  15.      ColumnAggregationNullResponseSumResponse.getDefaultInstance());
  16.  int sumResult = 0;
  17.  int expectedResult = 0;
  18.  for (Map.Entry<byte[], ColumnAggregationNullResponseSumResponse> e :
  19.    results.entrySet()) {
  20.   LOG.info("Got value " + e.getValue().getSum() + " for region "
  21.     + Bytes.toStringBinary(e.getKey()));
  22.   sumResult += e.getValue().getSum();
  23.  }
  24.  for (int i = 0; i < rowSeperator2; i++) {
  25.   expectedResult += i;
  26.  }
  27.  assertEquals("Invalid result", expectedResult, sumResult);
  28.  table.close();
  29. }

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

  1. @Test
  2.  public void testCoprocessorServiceLoadedByMaster() throws Throwable {
  3.   TEST_UTIL.getAdmin().coprocessorService().callBlockingMethod(
  4.       DummyCoprocessorService.getDescriptor().findMethodByName("dummyCall"), null,
  5.       DummyRequest.newBuilder().setValue(MASTER).build(), DummyResponse.getDefaultInstance());
  6.   assertEquals(MASTER, DummyCoprocessorService.numMaster);
  8.   TEST_UTIL.getAdmin().coprocessorService(
  9.     TEST_UTIL.getHBaseCluster().getRegionServer(0).getServerName()).callBlockingMethod(
  10.       DummyCoprocessorService.getDescriptor().findMethodByName("dummyCall"), null,
  11.       DummyRequest.newBuilder().setValue(REGIONSERVER).build(),
  12.       DummyResponse.getDefaultInstance());
  13.   assertEquals(REGIONSERVER, DummyCoprocessorService.numRegionServer);
  15.   TEST_UTIL.getConnection().getTable(TableName.valueOf("hbase:meta")).batchCoprocessorService(
  16.     DummyCoprocessorService.getDescriptor().findMethodByName("dummyCall"),
  17.     DummyRequest.newBuilder().setValue(REGION).build(), Bytes.toBytes(""), Bytes.toBytes(""),
  18.     DummyResponse.getDefaultInstance());
  19.   assertEquals(REGION, DummyCoprocessorService.numRegion);
  20.  }
  21. }

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

  1. @Test
  2.  public void testCoprocessorServiceLoadedByMaster() throws Throwable {
  3.   TEST_UTIL.getAdmin().coprocessorService().callBlockingMethod(
  4.       DummyCoprocessorService.getDescriptor().findMethodByName("dummyCall"), null,
  5.       DummyRequest.newBuilder().setValue(MASTER).build(), DummyResponse.getDefaultInstance());
  6.   assertEquals(MASTER, DummyCoprocessorService.numMaster);
  8.   TEST_UTIL.getAdmin().coprocessorService(
  9.     TEST_UTIL.getHBaseCluster().getRegionServer(0).getServerName()).callBlockingMethod(
  10.       DummyCoprocessorService.getDescriptor().findMethodByName("dummyCall"), null,
  11.       DummyRequest.newBuilder().setValue(REGIONSERVER).build(),
  12.       DummyResponse.getDefaultInstance());
  13.   assertEquals(REGIONSERVER, DummyCoprocessorService.numRegionServer);
  15.   TEST_UTIL.getConnection().getTable(TableName.valueOf("hbase:meta")).batchCoprocessorService(
  16.     DummyCoprocessorService.getDescriptor().findMethodByName("dummyCall"),
  17.     DummyRequest.newBuilder().setValue(REGION).build(), Bytes.toBytes(""), Bytes.toBytes(""),
  18.     DummyResponse.getDefaultInstance());
  19.   assertEquals(REGION, DummyCoprocessorService.numRegion);
  20.  }
  21. }

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

Table

相关文章

    查看更多

    热门标签

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

    最新文章

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