Java NoopRequest类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.apache.hadoop.hbase.coprocessor.protobuf.generated.PingProtos.NoopRequest类的典型用法代码示例。如果您正苦于以下问题：Java NoopRequest类的具体用法？Java NoopRequest怎么用？Java NoopRequest使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

NoopRequest类属于org.apache.hadoop.hbase.coprocessor.protobuf.generated.PingProtos包，在下文中一共展示了NoopRequest类的8个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: noop

import org.apache.hadoop.hbase.coprocessor.protobuf.generated.PingProtos.NoopRequest; //导入依赖的package包/类
private Map<byte [], String> noop(final Table table, final byte [] start,
    final byte [] end)
throws ServiceException, Throwable {
  return table.coprocessorService(PingProtos.PingService.class, start, end,
      new Batch.Call<PingProtos.PingService, String>() {
        @Override
        public String call(PingProtos.PingService instance) throws IOException {
          BlockingRpcCallback<PingProtos.NoopResponse> rpcCallback =
            new BlockingRpcCallback<PingProtos.NoopResponse>();
          PingProtos.NoopRequest.Builder builder = PingProtos.NoopRequest.newBuilder();
          instance.noop(null, builder.build(), rpcCallback);
          rpcCallback.get();
          // Looks like null is expected when void.  That is what the test below is looking for
          return null;
        }
      });
}

开发者ID:fengchen8086，项目名称:ditb，代码行数:18，代码来源:TestServerCustomProtocol.java

示例2: noop

import org.apache.hadoop.hbase.coprocessor.protobuf.generated.PingProtos.NoopRequest; //导入依赖的package包/类
private Map<byte [], String> noop(final HTable table, final byte [] start,
    final byte [] end)
throws ServiceException, Throwable {
  return table.coprocessorService(PingProtos.PingService.class, start, end,
      new Batch.Call<PingProtos.PingService, String>() {
        @Override
        public String call(PingProtos.PingService instance) throws IOException {
          BlockingRpcCallback<PingProtos.NoopResponse> rpcCallback =
            new BlockingRpcCallback<PingProtos.NoopResponse>();
          PingProtos.NoopRequest.Builder builder = PingProtos.NoopRequest.newBuilder();
          instance.noop(null, builder.build(), rpcCallback);
          rpcCallback.get();
          // Looks like null is expected when void.  That is what the test below is looking for
          return null;
        }
      });
}

开发者ID:tenggyut，项目名称:HIndex，代码行数:18，代码来源:TestServerCustomProtocol.java

示例3: noop

import org.apache.hadoop.hbase.coprocessor.protobuf.generated.PingProtos.NoopRequest; //导入依赖的package包/类
private Map<byte [], String> noop(final Table table, final byte [] start,
    final byte [] end)
throws ServiceException, Throwable {
  return table.coprocessorService(PingProtos.PingService.class, start, end,
      new Batch.Call<PingProtos.PingService, String>() {
        @Override
        public String call(PingProtos.PingService instance) throws IOException {
          CoprocessorRpcUtils.BlockingRpcCallback<PingProtos.NoopResponse> rpcCallback =
            new CoprocessorRpcUtils.BlockingRpcCallback<>();
          PingProtos.NoopRequest.Builder builder = PingProtos.NoopRequest.newBuilder();
          instance.noop(null, builder.build(), rpcCallback);
          rpcCallback.get();
          // Looks like null is expected when void.  That is what the test below is looking for
          return null;
        }
      });
}

开发者ID:apache，项目名称:hbase，代码行数:18，代码来源:TestServerCustomProtocol.java

示例4: noop

import org.apache.hadoop.hbase.coprocessor.protobuf.generated.PingProtos.NoopRequest; //导入依赖的package包/类
@Override
public void noop(RpcController controller, NoopRequest request,
    RpcCallback<NoopResponse> callback) {
  callback.run(NoopResponse.newBuilder().build());
}

开发者ID:fengchen8086，项目名称:ditb，代码行数:6，代码来源:TestAccessController.java

示例5: testCoprocessorExec

import org.apache.hadoop.hbase.coprocessor.protobuf.generated.PingProtos.NoopRequest; //导入依赖的package包/类
@Test (timeout=180000)
public void testCoprocessorExec() throws Exception {
  // Set up our ping endpoint service on all regions of our test table
  for (JVMClusterUtil.RegionServerThread thread:
      TEST_UTIL.getMiniHBaseCluster().getRegionServerThreads()) {
    HRegionServer rs = thread.getRegionServer();
    for (Region region: rs.getOnlineRegions(TEST_TABLE)) {
      region.getCoprocessorHost().load(PingCoprocessor.class,
        Coprocessor.PRIORITY_USER, conf);
    }
  }

  // Create users for testing, and grant EXEC privileges on our test table
  // only to user A
  User userA = User.createUserForTesting(conf, "UserA", new String[0]);
  User userB = User.createUserForTesting(conf, "UserB", new String[0]);

  grantOnTable(TEST_UTIL, userA.getShortName(),
    TEST_TABLE, null, null,
    Permission.Action.EXEC);
  try {
    // Create an action for invoking our test endpoint
    AccessTestAction execEndpointAction = new AccessTestAction() {
      @Override
      public Object run() throws Exception {
        try (Connection conn = ConnectionFactory.createConnection(conf);
            Table t = conn.getTable(TEST_TABLE);) {
          BlockingRpcChannel service = t.coprocessorService(HConstants.EMPTY_BYTE_ARRAY);
          PingCoprocessor.newBlockingStub(service).noop(null, NoopRequest.newBuilder().build());
        }
        return null;
      }
    };

    String namespace = TEST_TABLE.getNamespaceAsString();
    // Now grant EXEC to the entire namespace to user B
    grantOnNamespace(TEST_UTIL, userB.getShortName(), namespace, Permission.Action.EXEC);
    // User B should now be allowed also
    verifyAllowed(execEndpointAction, userA, userB);

    revokeFromNamespace(TEST_UTIL, userB.getShortName(), namespace, Permission.Action.EXEC);
    // Verify that EXEC permission is checked correctly
    verifyDenied(execEndpointAction, userB);
    verifyAllowed(execEndpointAction, userA);
  } finally {
    // Cleanup, revoke the userA privileges
    revokeFromTable(TEST_UTIL, userA.getShortName(), TEST_TABLE, null, null,
      Permission.Action.EXEC);
  }
}

开发者ID:fengchen8086，项目名称:ditb，代码行数:51，代码来源:TestAccessController.java

示例6: testCoprocessorExec

import org.apache.hadoop.hbase.coprocessor.protobuf.generated.PingProtos.NoopRequest; //导入依赖的package包/类
@Test
public void testCoprocessorExec() throws Exception {
  // Set up our ping endpoint service on all regions of our test table
  for (JVMClusterUtil.RegionServerThread thread:
      TEST_UTIL.getMiniHBaseCluster().getRegionServerThreads()) {
    HRegionServer rs = thread.getRegionServer();
    for (HRegion region: rs.getOnlineRegions(TEST_TABLE.getTableName())) {
      region.getCoprocessorHost().load(PingCoprocessor.class,
        Coprocessor.PRIORITY_USER, conf);
    }
  }

  // Create users for testing, and grant EXEC privileges on our test table
  // only to user A
  User userA = User.createUserForTesting(conf, "UserA", new String[0]);
  User userB = User.createUserForTesting(conf, "UserB", new String[0]);

  grantOnTable(TEST_UTIL, userA.getShortName(),
    TEST_TABLE.getTableName(), null, null,
    Permission.Action.EXEC);

  // Create an action for invoking our test endpoint
  AccessTestAction execEndpointAction = new AccessTestAction() {
    @Override
    public Object run() throws Exception {
      Table t = new HTable(conf, TEST_TABLE.getTableName());
      try {
        BlockingRpcChannel service = t.coprocessorService(HConstants.EMPTY_BYTE_ARRAY);
        PingCoprocessor.newBlockingStub(service).noop(null, NoopRequest.newBuilder().build());
      } finally {
        t.close();
      }
      return null;
    }
  };

  // Verify that EXEC permission is checked correctly
  verifyDenied(execEndpointAction, userB);
  verifyAllowed(execEndpointAction, userA);

  // Now grant EXEC to the entire namespace to user B
  grantOnNamespace(TEST_UTIL, userB.getShortName(),
    TEST_TABLE.getTableName().getNamespaceAsString(),
    Permission.Action.EXEC);

  // User B should now be allowed also
  verifyAllowed(execEndpointAction, userA, userB);
}

开发者ID:grokcoder，项目名称:pbase，代码行数:49，代码来源:TestAccessController.java

示例7: testCoprocessorExec

import org.apache.hadoop.hbase.coprocessor.protobuf.generated.PingProtos.NoopRequest; //导入依赖的package包/类
@Test
public void testCoprocessorExec() throws Exception {
  // Set up our ping endpoint service on all regions of our test table
  for (JVMClusterUtil.RegionServerThread thread:
      TEST_UTIL.getMiniHBaseCluster().getRegionServerThreads()) {
    HRegionServer rs = thread.getRegionServer();
    for (HRegion region: rs.getOnlineRegions(TEST_TABLE.getTableName())) {
      region.getCoprocessorHost().load(PingCoprocessor.class,
        Coprocessor.PRIORITY_USER, conf);
    }
  }

  // Create users for testing, and grant EXEC privileges on our test table
  // only to user A
  User userA = User.createUserForTesting(conf, "UserA", new String[0]);
  User userB = User.createUserForTesting(conf, "UserB", new String[0]);

  grantOnTable(TEST_UTIL, userA.getShortName(),
    TEST_TABLE.getTableName(), null, null,
    Permission.Action.EXEC);

  // Create an action for invoking our test endpoint
  AccessTestAction execEndpointAction = new AccessTestAction() {
    @Override
    public Object run() throws Exception {
      HTable t = new HTable(conf, TEST_TABLE.getTableName());
      try {
        BlockingRpcChannel service = t.coprocessorService(HConstants.EMPTY_BYTE_ARRAY);
        PingCoprocessor.newBlockingStub(service).noop(null, NoopRequest.newBuilder().build());
      } finally {
        t.close();
      }
      return null;
    }
  };

  // Verify that EXEC permission is checked correctly
  verifyDenied(execEndpointAction, userB);
  verifyAllowed(execEndpointAction, userA);

  // Now grant EXEC to the entire namespace to user B
  grantOnNamespace(TEST_UTIL, userB.getShortName(),
    TEST_TABLE.getTableName().getNamespaceAsString(),
    Permission.Action.EXEC);

  // User B should now be allowed also
  verifyAllowed(execEndpointAction, userA, userB);
}

开发者ID:tenggyut，项目名称:HIndex，代码行数:49，代码来源:TestAccessController.java

示例8: testCoprocessorExec

import org.apache.hadoop.hbase.coprocessor.protobuf.generated.PingProtos.NoopRequest; //导入依赖的package包/类
@Test (timeout=180000)
public void testCoprocessorExec() throws Exception {
  // Set up our ping endpoint service on all regions of our test table
  for (JVMClusterUtil.RegionServerThread thread:
      TEST_UTIL.getMiniHBaseCluster().getRegionServerThreads()) {
    HRegionServer rs = thread.getRegionServer();
    for (HRegion region: rs.getRegions(TEST_TABLE)) {
      region.getCoprocessorHost().load(PingCoprocessor.class,
        Coprocessor.PRIORITY_USER, conf);
    }
  }

  // Create users for testing, and grant EXEC privileges on our test table
  // only to user A
  User userA = User.createUserForTesting(conf, "UserA", new String[0]);
  User userB = User.createUserForTesting(conf, "UserB", new String[0]);

  grantOnTable(TEST_UTIL, userA.getShortName(),
    TEST_TABLE, null, null,
    Permission.Action.EXEC);
  try {
    // Create an action for invoking our test endpoint
    AccessTestAction execEndpointAction = new AccessTestAction() {
      @Override
      public Object run() throws Exception {
        try (Connection conn = ConnectionFactory.createConnection(conf);
            Table t = conn.getTable(TEST_TABLE)) {
          BlockingRpcChannel service = t.coprocessorService(HConstants.EMPTY_BYTE_ARRAY);
          PingCoprocessor.newBlockingStub(service).noop(null, NoopRequest.newBuilder().build());
        }
        return null;
      }
    };

    String namespace = TEST_TABLE.getNamespaceAsString();
    // Now grant EXEC to the entire namespace to user B
    grantOnNamespace(TEST_UTIL, userB.getShortName(), namespace, Permission.Action.EXEC);
    // User B should now be allowed also
    verifyAllowed(execEndpointAction, userA, userB);

    revokeFromNamespace(TEST_UTIL, userB.getShortName(), namespace, Permission.Action.EXEC);
    // Verify that EXEC permission is checked correctly
    verifyDenied(execEndpointAction, userB);
    verifyAllowed(execEndpointAction, userA);
  } finally {
    // Cleanup, revoke the userA privileges
    revokeFromTable(TEST_UTIL, userA.getShortName(), TEST_TABLE, null, null,
      Permission.Action.EXEC);
  }
}

开发者ID:apache，项目名称:hbase，代码行数:51，代码来源:TestAccessController.java

注：本文中的org.apache.hadoop.hbase.coprocessor.protobuf.generated.PingProtos.NoopRequest类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。