Constructor Detail

• ConnectionManager.HConnectionImplementation.StubMaker

  ConnectionManager.HConnectionImplementation.StubMaker()

Method Detail

• getServiceName

  protected abstract String getServiceName()

  Returns the name of the service stub being created.

• makeStub

  protected abstract Object makeStub(com.google.protobuf.BlockingRpcChannel channel)

  Make stub and cache it internal so can be used later doing the isMasterRunning call.

  Parameters:

  channel -

• isMasterRunning

  protected abstract void isMasterRunning()
                                   throws com.google.protobuf.ServiceException

  Once setup, check it works by doing isMasterRunning check.

  Throws:

  com.google.protobuf.ServiceException

• makeStubNoRetries

  private Object makeStubNoRetries()
                            throws IOException,
                                   org.apache.zookeeper.KeeperException,
                                   com.google.protobuf.ServiceException

  Create a stub. Try once only. It is not typed because there is no common type to protobuf services nor their interfaces. Let the caller do appropriate casting.

  Returns:

  A stub for master services.

  Throws:

  IOException

  org.apache.zookeeper.KeeperException

  com.google.protobuf.ServiceException

• makeStub

  Object makeStub()
            throws IOException

  Create a stub against the master. Retry if necessary.

  Returns:

  A stub to do intf against the master

  Throws:

  MasterNotRunningException

  IOException