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

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

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

Table.coprocessorService介绍

[英]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), and invokes the passed org.apache.hadoop.hbase.client.coprocessor.Batch.Call#call method with each com.facebook.presto.hbase.$internal.com.google.protobuf.Service instance.
[中]创建给定com的实例。脸谱网。急板地。hbase$内部的通用域名格式。谷歌。protobuf。每个表区域的服务子类，范围从startKey行到endKey行（包括在内），并调用传递的组织。阿帕奇。hadoop。hbase。客户协处理器。一批调用#对每个com调用方法。脸谱网。急板地。hbase$内部的通用域名格式。谷歌。protobuf。服务实例。

代码示例

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

  1. private Map<byte [], String> ping(final Table table, final byte [] start, final byte [] end)
  2.     throws ServiceException, Throwable {
  3.  return table.coprocessorService(PingProtos.PingService.class, start, end,
  4.   new Batch.Call<PingProtos.PingService, String>() {
  5.    @Override
  6.    public String call(PingProtos.PingService instance) throws IOException {
  7.     return doPing(instance);
  8.    }
  9.   });
  10. }

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

  1. private static BlockingInterface getAccessControlServiceStub(Table ht)
  2.   throws IOException {
  3.  CoprocessorRpcChannel service = ht.coprocessorService(HConstants.EMPTY_START_ROW);
  4.  BlockingInterface protocol =
  5.    AccessControlProtos.AccessControlService.newBlockingStub(service);
  6.  return protocol;
  7. }

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

  1. private Map<byte [], String> noop(final Table table, final byte [] start, final byte [] end)
  2.     throws ServiceException, Throwable {
  3.  return table.coprocessorService(PingProtos.PingService.class, start, end,
  4.    new Batch.Call<PingProtos.PingService, String>() {
  5.     @Override
  6.     public String call(PingProtos.PingService instance) throws IOException {
  7.      CoprocessorRpcUtils.BlockingRpcCallback<PingProtos.NoopResponse> rpcCallback =
  8.       new CoprocessorRpcUtils.BlockingRpcCallback<>();
  9.      PingProtos.NoopRequest.Builder builder = PingProtos.NoopRequest.newBuilder();
  10.      instance.noop(null, builder.build(), rpcCallback);
  11.      rpcCallback.get();
  12.      // Looks like null is expected when void.  That is what the test below is looking for
  13.      return null;
  14.     }
  15.    });
  16. }

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

  1. @Override
  2.  public Object run() throws Exception {
  3.   try (Connection connection = ConnectionFactory.createConnection(conf);
  4.     Table acl = connection.getTable(AccessControlLists.ACL_TABLE_NAME)) {
  5.    BlockingRpcChannel service = acl.coprocessorService(HConstants.EMPTY_START_ROW);
  6.    AccessControlService.BlockingInterface protocol =
  7.      AccessControlService.newBlockingStub(service);
  8.    AccessControlUtil.getUserPermissions(null, protocol, Bytes.toBytes(TEST_NAMESPACE));
  9.   }
  10.   return null;
  11.  }
  12. };

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

  1. @Override
  2.  public Object run() throws Exception {
  3.   try (Connection conn = ConnectionFactory.createConnection(conf);
  4.     Table acl = conn.getTable(AccessControlLists.ACL_TABLE_NAME)) {
  5.    BlockingRpcChannel service = acl.coprocessorService(TEST_TABLE.getName());
  6.    AccessControlService.BlockingInterface protocol =
  7.      AccessControlService.newBlockingStub(service);
  8.    AccessControlUtil.getUserPermissions(null, protocol, Bytes.toBytes(namespace1), "dummy");
  9.   }
  10.   return null;
  11.  }
  12. };

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

  1. @Override
  2.  public Object run() throws Exception {
  3.   try (Connection connection = ConnectionFactory.createConnection(conf);
  4.     Table acl = connection.getTable(AccessControlLists.ACL_TABLE_NAME)) {
  5.    BlockingRpcChannel service = acl.coprocessorService(HConstants.EMPTY_START_ROW);
  6.    AccessControlService.BlockingInterface protocol =
  7.      AccessControlService.newBlockingStub(service);
  8.    AccessControlUtil.grant(null, protocol, testUser, TEST_NAMESPACE, false, Action.WRITE);
  9.   }
  10.   return null;
  11.  }
  12. };

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

  1. @Override
  2.  public Object run() throws Exception {
  3.   try (Connection connection = ConnectionFactory.createConnection(conf);
  4.     Table acl = connection.getTable(AccessControlLists.ACL_TABLE_NAME)) {
  5.    BlockingRpcChannel service = acl.coprocessorService(HConstants.EMPTY_START_ROW);
  6.    AccessControlService.BlockingInterface protocol =
  7.      AccessControlService.newBlockingStub(service);
  8.    AccessControlUtil.revoke(null, protocol, testUser, TEST_NAMESPACE, Action.WRITE);
  9.   }
  10.   return null;
  11.  }
  12. };

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

  1. @Override
  2.  public Object run() throws Exception {
  3.   try(Connection conn = ConnectionFactory.createConnection(conf);
  4.     Table acl = conn.getTable(AccessControlLists.ACL_TABLE_NAME)) {
  5.    BlockingRpcChannel service = acl.coprocessorService(HConstants.EMPTY_START_ROW);
  6.    AccessControlService.BlockingInterface protocol =
  7.     AccessControlService.newBlockingStub(service);
  8.    AccessControlUtil.getUserPermissions(null, protocol);
  9.   }
  10.   return null;
  11.  }
  12. };

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

  1. private void swapRows(Table table) throws Throwable {
  2.  CoprocessorRpcChannel channel = table.coprocessorService(ROW);
  3.  RowProcessorEndpoint.RowSwapProcessor processor =
  4.    new RowProcessorEndpoint.RowSwapProcessor(ROW, ROW2);
  5.  RowProcessorService.BlockingInterface service =
  6.    RowProcessorService.newBlockingStub(channel);
  7.  ProcessRequest request = RowProcessorClient.getRowProcessorPB(processor);
  8.  service.process(null, request);
  9. }

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

  1. @Override
  2.  public Object run() throws Exception {
  3.   try(Connection conn = ConnectionFactory.createConnection(conf);
  4.     Table acl = conn.getTable(AccessControlLists.ACL_TABLE_NAME)){
  5.    BlockingRpcChannel service = acl.coprocessorService(TEST_TABLE.getName());
  6.    AccessControlService.BlockingInterface protocol =
  7.      AccessControlService.newBlockingStub(service);
  8.    AccessControlUtil.getUserPermissions(null, protocol, TEST_TABLE);
  9.   }
  10.   return null;
  11.  }
  12. };

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

  1. @Override
  2.  public Object run() throws Exception {
  3.   try (Connection conn = ConnectionFactory.createConnection(conf);
  4.     Table acl = conn.getTable(AccessControlLists.ACL_TABLE_NAME)) {
  5.    BlockingRpcChannel service = acl.coprocessorService(TEST_TABLE.getName());
  6.    AccessControlService.BlockingInterface protocol =
  7.      AccessControlService.newBlockingStub(service);
  8.    AccessControlUtil.getUserPermissions(null, protocol, "dummy");
  9.   }
  10.   return null;
  11.  }
  12. };

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

  1. @Override
  2.  public Object run() throws Exception {
  3.   try (Connection conn = ConnectionFactory.createConnection(conf);
  4.     Table acl = conn.getTable(AccessControlLists.ACL_TABLE_NAME)) {
  5.    BlockingRpcChannel service = acl.coprocessorService(TEST_TABLE.getName());
  6.    AccessControlService.BlockingInterface protocol =
  7.      AccessControlService.newBlockingStub(service);
  8.    AccessControlUtil.getUserPermissions(null, protocol, TEST_TABLE, TEST_FAMILY,
  9.     TEST_QUALIFIER, "dummy");
  10.   }
  11.   return null;
  12.  }
  13. };

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

  1. @Override
  2.  public Object run() throws Exception {
  3.   try (Connection conn = ConnectionFactory.createConnection(conf);
  4.     Table acl = conn.getTable(AccessControlLists.ACL_TABLE_NAME)) {
  5.    BlockingRpcChannel service = acl.coprocessorService(TEST_TABLE.getName());
  6.    AccessControlService.BlockingInterface protocol =
  7.      AccessControlService.newBlockingStub(service);
  8.    Permission.Action[] actions = { Permission.Action.READ, Permission.Action.WRITE };
  9.    AccessControlUtil.hasPermission(null, protocol, TEST_TABLE, TEST_FAMILY,
  10.     HConstants.EMPTY_BYTE_ARRAY, "dummy", actions);
  11.   }
  12.   return null;
  13.  }
  14. };

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

  1. @Override
  2.  public Object run() throws Exception {
  3.   try (Connection conn = ConnectionFactory.createConnection(conf);
  4.     Table t = conn.getTable(TEST_TABLE)) {
  5.    BlockingRpcChannel service = t.coprocessorService(HConstants.EMPTY_BYTE_ARRAY);
  6.    PingCoprocessor.newBlockingStub(service).noop(null, NoopRequest.newBuilder().build());
  7.   }
  8.   return null;
  9.  }
  10. };

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

  1. @Test
  2. public void testCoprocessorError() throws Exception {
  3.  Configuration configuration = new Configuration(util.getConfiguration());
  4.  // Make it not retry forever
  5.  configuration.setInt(HConstants.HBASE_CLIENT_RETRIES_NUMBER, 1);
  6.  Table table = util.getConnection().getTable(TEST_TABLE);
  7.  try {
  8.   CoprocessorRpcChannel protocol = table.coprocessorService(ROWS[0]);
  9.   TestRpcServiceProtos.TestProtobufRpcProto.BlockingInterface service =
  10.     TestRpcServiceProtos.TestProtobufRpcProto.newBlockingStub(protocol);
  11.   service.error(null, TestProtos.EmptyRequestProto.getDefaultInstance());
  12.   fail("Should have thrown an exception");
  13.  } catch (ServiceException e) {
  14.  } finally {
  15.   table.close();
  16.  }
  17. }

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

  1. @Override
  2.  public Object run() throws Exception {
  3.   try (Connection conn = ConnectionFactory.createConnection(conf);
  4.     Table acl = conn.getTable(AccessControlLists.ACL_TABLE_NAME)) {
  5.    BlockingRpcChannel service = acl.coprocessorService(TEST_TABLE.getName());
  6.    AccessControlService.BlockingInterface protocol =
  7.      AccessControlService.newBlockingStub(service);
  8.    AccessControlUtil.revoke(null, protocol, USER_RO.getShortName(), TEST_TABLE, TEST_FAMILY,
  9.     null, Action.READ);
  10.   }
  11.   return null;
  12.  }
  13. };

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

  1. @Override
  2.  public Object run() throws Exception {
  3.   try (Connection conn = ConnectionFactory.createConnection(conf);
  4.     Table acl = conn.getTable(AccessControlLists.ACL_TABLE_NAME)) {
  5.    BlockingRpcChannel service = acl.coprocessorService(TEST_TABLE.getName());
  6.    AccessControlService.BlockingInterface protocol =
  7.      AccessControlService.newBlockingStub(service);
  8.    AccessControlUtil.grant(null, protocol, USER_RO.getShortName(), TEST_TABLE, TEST_FAMILY,
  9.     null, false, Action.READ);
  10.   }
  11.   return null;
  12.  }
  13. };

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

  1. private int incrementCounter(Table table) throws Throwable {
  2.  CoprocessorRpcChannel channel = table.coprocessorService(ROW);
  3.  RowProcessorEndpoint.IncrementCounterProcessor processor =
  4.    new RowProcessorEndpoint.IncrementCounterProcessor(ROW);
  5.  RowProcessorService.BlockingInterface service =
  6.    RowProcessorService.newBlockingStub(channel);
  7.  ProcessRequest request = RowProcessorClient.getRowProcessorPB(processor);
  8.  ProcessResponse protoResult = service.process(null, request);
  9.  IncCounterProcessorResponse response = IncCounterProcessorResponse
  10.    .parseFrom(protoResult.getRowProcessorResult());
  11.  Integer result = response.getResponse();
  12.  return result;
  13. }

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

  1. @Test
  2. public void testTimeout() throws Throwable {
  3.  prepareTestData();
  4.  CoprocessorRpcChannel channel = table.coprocessorService(ROW);
  5.  RowProcessorEndpoint.TimeoutProcessor processor =
  6.    new RowProcessorEndpoint.TimeoutProcessor(ROW);
  7.  RowProcessorService.BlockingInterface service =
  8.    RowProcessorService.newBlockingStub(channel);
  9.  ProcessRequest request = RowProcessorClient.getRowProcessorPB(processor);
  10.  boolean exceptionCaught = false;
  11.  try {
  12.   service.process(null, request);
  13.  } catch (Exception e) {
  14.   exceptionCaught = true;
  15.  }
  16.  assertTrue(exceptionCaught);
  17. }

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

  1. public static void checkTablePerms(HBaseTestingUtility testUtil, TableName table,
  2.   Permission... perms) throws IOException {
  3.  CheckPermissionsRequest.Builder request = CheckPermissionsRequest.newBuilder();
  4.  for (Permission p : perms) {
  5.   request.addPermission(AccessControlUtil.toPermission(p));
  6.  }
  7.  try(Connection conn = ConnectionFactory.createConnection(testUtil.getConfiguration());
  8.    Table acl = conn.getTable(table)) {
  9.   AccessControlService.BlockingInterface protocol =
  10.    AccessControlService.newBlockingStub(acl.coprocessorService(new byte[0]));
  11.   try {
  12.    protocol.checkPermissions(null, request.build());
  13.   } catch (ServiceException se) {
  14.    ProtobufUtil.toIOException(se);
  15.   }
  16.  }
  17. }

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

Table

相关文章

    查看更多

    热门标签

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

    最新文章

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