Examples of org.apache.hadoop.hbase.ipc.CoprocessorRpcChannel

org.apache.hadoop.hbase.ipc.CoprocessorRpcChannel
Base class which provides clients with an RPC connection to call coprocessor endpoint {@link Service}s. Note that clients should not use this class directly, except through {@link org.apache.hadoop.hbase.client.HTableInterface#coprocessorService(byte[])}.


  @Test
  public void testDoubleScan() throws Throwable {
    prepareTestData();


    CoprocessorRpcChannel channel = table.coprocessorService(ROW);
    RowProcessorEndpoint.FriendsOfFriendsProcessor processor =
        new RowProcessorEndpoint.FriendsOfFriendsProcessor(ROW, A);
    RowProcessorService.BlockingInterface service =
        RowProcessorService.newBlockingStub(channel);
    ProcessRequest request = RowProcessorClient.getRowProcessorPB(processor);

View Full Code Here

      }
    }
  }


  private int incrementCounter(HTable table) throws Throwable {
    CoprocessorRpcChannel channel = table.coprocessorService(ROW);
    RowProcessorEndpoint.IncrementCounterProcessor processor =
        new RowProcessorEndpoint.IncrementCounterProcessor(ROW);
    RowProcessorService.BlockingInterface service =
        RowProcessorService.newBlockingStub(channel);
    ProcessRequest request = RowProcessorClient.getRowProcessorPB(processor);

View Full Code Here

      }
    }
  }


  private void swapRows(HTable table) throws Throwable {
    CoprocessorRpcChannel channel = table.coprocessorService(ROW);
    RowProcessorEndpoint.RowSwapProcessor processor =
        new RowProcessorEndpoint.RowSwapProcessor(ROW, ROW2);
    RowProcessorService.BlockingInterface service =
        RowProcessorService.newBlockingStub(channel);
    ProcessRequest request = RowProcessorClient.getRowProcessorPB(processor);

View Full Code Here

  }


  @Test
  public void testTimeout() throws Throwable {
    prepareTestData();
    CoprocessorRpcChannel channel = table.coprocessorService(ROW);
    RowProcessorEndpoint.TimeoutProcessor processor =
        new RowProcessorEndpoint.TimeoutProcessor(ROW);
    RowProcessorService.BlockingInterface service =
        RowProcessorService.newBlockingStub(channel);
    ProcessRequest request = RowProcessorClient.getRowProcessorPB(processor);

View Full Code Here

    return new HTable(conf, ACL_TABLE_NAME);
  }


  private static BlockingInterface getAccessControlServiceStub(HTable ht)
      throws IOException {
    CoprocessorRpcChannel service = ht.coprocessorService(HConstants.EMPTY_START_ROW);
    BlockingInterface protocol =
        AccessControlProtos.AccessControlService.newBlockingStub(service);
    return protocol;
  }

View Full Code Here

    Table ht = null;
    Admin ha = null;
    try {
      ha = new HBaseAdmin(conf);
      ht = new HTable(conf, ACL_TABLE_NAME);
      CoprocessorRpcChannel service = ht.coprocessorService(HConstants.EMPTY_START_ROW);
      BlockingInterface protocol = AccessControlProtos.AccessControlService
          .newBlockingStub(service);
      HTableDescriptor[] htds = null;


      if (tableRegex == null || tableRegex.isEmpty()) {

View Full Code Here

0 1 2 3 4 5 6 7 8

TOP

Related Classes of org.apache.hadoop.hbase.ipc.CoprocessorRpcChannel

com.google.protobuf.Message

org.apache.hadoop.hbase.catalog.MetaEditor

org.apache.hadoop.hbase.client.coprocessor.SecureBulkLoadClient

org.apache.hadoop.hbase.client.TestFromClientSide

org.apache.hadoop.hbase.coprocessor.TestCoprocessorEndpoint

org.apache.hadoop.hbase.coprocessor.TestHTableWrapper

org.apache.hadoop.hbase.coprocessor.TestRowProcessorEndpoint

org.apache.hadoop.hbase.MetaTableAccessor

org.apache.hadoop.hbase.security.access.AccessControlClient

org.apache.hadoop.hbase.security.token.TokenUtil

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.