Package org.apache.hadoop.hbase.client

Class SyncCoprocessorRpcChannel

java.lang.Object
org.apache.hadoop.hbase.client.SyncCoprocessorRpcChannel
All Implemented Interfaces:
com.google.protobuf.BlockingRpcChannel, com.google.protobuf.RpcChannel, CoprocessorRpcChannel
Direct Known Subclasses:
RegionCoprocessorRpcChannel
@Public abstract class SyncCoprocessorRpcChannel extends Object implements CoprocessorRpcChannel
Base class which provides clients with an RPC connection to call coprocessor endpoint Services. Note that clients should not use this class directly, except through Table.coprocessorService(byte[]).

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    private static final org.slf4j.Logger
    LOG
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    SyncCoprocessorRpcChannel()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    com.google.protobuf.Message
    callBlockingMethod(com.google.protobuf.Descriptors.MethodDescriptor method, com.google.protobuf.RpcController controller, com.google.protobuf.Message request, com.google.protobuf.Message responsePrototype)
     
    protected abstract com.google.protobuf.Message
    callExecService(com.google.protobuf.RpcController controller, com.google.protobuf.Descriptors.MethodDescriptor method, com.google.protobuf.Message request, com.google.protobuf.Message responsePrototype)
     
    void
    callMethod(com.google.protobuf.Descriptors.MethodDescriptor method, com.google.protobuf.RpcController controller, com.google.protobuf.Message request, com.google.protobuf.Message responsePrototype, com.google.protobuf.RpcCallback<com.google.protobuf.Message> callback)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Field Details

    • LOG

      private static final org.slf4j.Logger LOG

  • Constructor Details

  • Method Details

    • callMethod

      @Private public void callMethod(com.google.protobuf.Descriptors.MethodDescriptor method, com.google.protobuf.RpcController controller, com.google.protobuf.Message request, com.google.protobuf.Message responsePrototype, com.google.protobuf.RpcCallback<com.google.protobuf.Message> callback)
      Specified by:
      callMethod in interface com.google.protobuf.RpcChannel

    • callBlockingMethod

      @Private public com.google.protobuf.Message callBlockingMethod(com.google.protobuf.Descriptors.MethodDescriptor method, com.google.protobuf.RpcController controller, com.google.protobuf.Message request, com.google.protobuf.Message responsePrototype) throws com.google.protobuf.ServiceException
      Specified by:
      callBlockingMethod in interface com.google.protobuf.BlockingRpcChannel
      Throws:
      com.google.protobuf.ServiceException

    • callExecService

      protected abstract com.google.protobuf.Message callExecService(com.google.protobuf.RpcController controller, com.google.protobuf.Descriptors.MethodDescriptor method, com.google.protobuf.Message request, com.google.protobuf.Message responsePrototype) throws IOException
      Throws:
      IOException