Examples of 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[])}.

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

      }
    }
  }


  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

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

      }
    }
  }


  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

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

  }


  @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

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


  /**
   * Performs an atomic multi-Mutate operation against the given table.
   */
  private static void multiMutate(HTable table, byte[] row, Mutation... mutations) throws IOException {
    CoprocessorRpcChannel channel = table.coprocessorService(row);
    MutateRowsRequest.Builder mmrBuilder = MutateRowsRequest.newBuilder();
    for (Mutation mutation : mutations) {
      if (mutation instanceof Put) {
        mmrBuilder.addMutationRequest(ProtobufUtil.toMutation(MutationType.PUT, mutation));
      } else if (mutation instanceof Delete) {

View Full Code Here

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


    MultiMutateRequest.Builder mrmBuilder = MultiMutateRequest.newBuilder();
    mrmBuilder.addMutationRequest(m1);
    mrmBuilder.addMutationRequest(m2);
    MultiMutateRequest mrm = mrmBuilder.build();
    CoprocessorRpcChannel channel = t.coprocessorService(ROW);
    MultiRowMutationService.BlockingInterface service =
       MultiRowMutationService.newBlockingStub(channel);
    service.mutateRows(null, mrm);
    Get g = new Get(ROW);
    Result r = t.get(g);

View Full Code Here

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


  @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);
    RowProcessorRequest request = RowProcessorClient.getRowProcessorPB(processor);

View Full Code Here

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

      }
    }
  }


  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);
    RowProcessorRequest request = RowProcessorClient.getRowProcessorPB(processor);

View Full Code Here

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

      }
    }
  }


  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);
    RowProcessorRequest request = RowProcessorClient.getRowProcessorPB(processor);

View Full Code Here

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

  }


  @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);
    RowProcessorRequest request = RowProcessorClient.getRowProcessorPB(processor);

View Full Code Here

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

    // Make it not retry forever
    configuration.setInt(HConstants.HBASE_CLIENT_RETRIES_NUMBER, 1);
    HTable table = new HTable(configuration, TEST_TABLE);


    try {
      CoprocessorRpcChannel protocol = table.coprocessorService(ROWS[0]);


      TestRpcServiceProtos.TestProtobufRpcProto.BlockingInterface service =
          TestRpcServiceProtos.TestProtobufRpcProto.newBlockingStub(protocol);


      service.error(null, TestProtos.EmptyRequestProto.getDefaultInstance());

View Full Code Here

0 1 2 3 4 5

TOP

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.