Java 类org.apache.hadoop.hbase.protobuf.generated.MasterProtos.MasterService 实例源码

/**
 * @return list of blocking services and their security info classes that this server supports
 */
protected List<BlockingServiceAndInterface> getServices() {
  List<BlockingServiceAndInterface> bssi = new ArrayList<BlockingServiceAndInterface>(4);
  bssi.add(new BlockingServiceAndInterface(
    MasterService.newReflectiveBlockingService(this),
    MasterService.BlockingInterface.class));
  bssi.add(new BlockingServiceAndInterface(
    RegionServerStatusService.newReflectiveBlockingService(this),
    RegionServerStatusService.BlockingInterface.class));
  bssi.addAll(super.getServices());
  return bssi;
}

public static CoprocessorServiceResponse execService(final RpcController controller,
  final MasterService.BlockingInterface client, final CoprocessorServiceCall call)
throws IOException {
  CoprocessorServiceRequest request = CoprocessorServiceRequest.newBuilder()
      .setCall(call).setRegion(
          RequestConverter.buildRegionSpecifier(REGION_NAME, HConstants.EMPTY_BYTE_ARRAY)).build();
  try {
    CoprocessorServiceResponse response =
        client.execMasterService(controller, request);
    return response;
  } catch (ServiceException se) {
    throw getRemoteException(se);
  }
}

/**
 * @return list of blocking services and their security info classes that this server supports
 */
protected List<BlockingServiceAndInterface> getServices() {
  List<BlockingServiceAndInterface> bssi = new ArrayList<BlockingServiceAndInterface>(4);
  bssi.add(new BlockingServiceAndInterface(
    MasterService.newReflectiveBlockingService(this),
    MasterService.BlockingInterface.class));
  bssi.add(new BlockingServiceAndInterface(
    RegionServerStatusService.newReflectiveBlockingService(this),
    RegionServerStatusService.BlockingInterface.class));
  bssi.addAll(super.getServices());
  return bssi;
}

public static CoprocessorServiceResponse execService(
  final MasterService.BlockingInterface client, final CoprocessorServiceCall call)
throws IOException {
  CoprocessorServiceRequest request = CoprocessorServiceRequest.newBuilder()
      .setCall(call).setRegion(
          RequestConverter.buildRegionSpecifier(REGION_NAME, HConstants.EMPTY_BYTE_ARRAY)).build();
  try {
    CoprocessorServiceResponse response =
        client.execMasterService(null, request);
    return response;
  } catch (ServiceException se) {
    throw getRemoteException(se);
  }
}

public static CoprocessorServiceResponse execService(
  final MasterService.BlockingInterface client, final CoprocessorServiceCall call)
throws IOException {
  CoprocessorServiceRequest request = CoprocessorServiceRequest.newBuilder()
      .setCall(call).setRegion(
          RequestConverter.buildRegionSpecifier(REGION_NAME, HConstants.EMPTY_BYTE_ARRAY)).build();
  try {
    CoprocessorServiceResponse response =
        client.execMasterService(null, request);
    return response;
  } catch (ServiceException se) {
    throw getRemoteException(se);
  }
}

/**
 * @return list of blocking services and their security info classes that this server supports
 */
protected List<BlockingServiceAndInterface> getServices() {
  List<BlockingServiceAndInterface> bssi = new ArrayList<BlockingServiceAndInterface>(4);
  bssi.add(new BlockingServiceAndInterface(
    MasterService.newReflectiveBlockingService(this),
    MasterService.BlockingInterface.class));
  bssi.add(new BlockingServiceAndInterface(
    RegionServerStatusService.newReflectiveBlockingService(this),
    RegionServerStatusService.BlockingInterface.class));
  bssi.addAll(super.getServices());
  return bssi;
}

public static CoprocessorServiceResponse execService(
  final MasterService.BlockingInterface client, final CoprocessorServiceCall call)
throws IOException {
  CoprocessorServiceRequest request = CoprocessorServiceRequest.newBuilder()
      .setCall(call).setRegion(
          RequestConverter.buildRegionSpecifier(REGION_NAME, HConstants.EMPTY_BYTE_ARRAY)).build();
  try {
    CoprocessorServiceResponse response =
        client.execMasterService(null, request);
    return response;
  } catch (ServiceException se) {
    throw getRemoteException(se);
  }
}

public static CoprocessorServiceResponse execService(
  final MasterService.BlockingInterface client, final CoprocessorServiceCall call)
throws IOException {
  CoprocessorServiceRequest request = CoprocessorServiceRequest.newBuilder()
      .setCall(call).setRegion(
          RequestConverter.buildRegionSpecifier(REGION_NAME, HConstants.EMPTY_BYTE_ARRAY)).build();
  try {
    CoprocessorServiceResponse response =
        client.execMasterService(null, request);
    return response;
  } catch (ServiceException se) {
    throw getRemoteException(se);
  }
}

@Override
public MasterService.BlockingInterface getMasterAdminService()
throws IOException {
  return ((ClusterConnection)this.connection).getMaster();
}

@Override
public MasterService.BlockingInterface getMaster() throws IOException {
  return wrappedConnection.getMaster();
}

@Override
protected String getServiceName() {
  return MasterService.getDescriptor().getName();
}

@Override
MasterService.BlockingInterface makeStub() throws IOException {
  return (MasterService.BlockingInterface)super.makeStub();
}

@Override
protected Object makeStub(BlockingRpcChannel channel) {
  this.stub = MasterService.newBlockingStub(channel);
  return this.stub;
}

@Override
public MasterService.BlockingInterface getMaster() throws MasterNotRunningException {
  return getKeepAliveMasterService();
}

@Override
public MasterService.BlockingInterface getMaster() throws IOException {
  return wrappedConnection.getMaster();
}

@Override
protected String getServiceName() {
    return MasterService.getDescriptor().getName();
}

@Override
MasterService.BlockingInterface makeStub() throws IOException {
    return (MasterService.BlockingInterface) super.makeStub();
}

@Override
protected Object makeStub(BlockingRpcChannel channel) {
    this.stub = MasterService.newBlockingStub(channel);
    return this.stub;
}

@Override
public MasterService.BlockingInterface getMaster() throws MasterNotRunningException {
    return getKeepAliveMasterService();
}

@Override
public MasterService.BlockingInterface getMaster()
throws IOException {
  HConnection conn = HConnectionManager.getConnection(conf);
  return conn.getMaster();
}

@Override
protected String getServiceName() {
  return MasterService.getDescriptor().getName();
}

@Override
@edu.umd.cs.findbugs.annotations.SuppressWarnings("SWL_SLEEP_WITH_LOCK_HELD")
MasterService.BlockingInterface makeStub() throws MasterNotRunningException {
  return (MasterService.BlockingInterface)super.makeStub();
}

@Override
protected Object makeStub(BlockingRpcChannel channel) {
  this.stub = MasterService.newBlockingStub(channel);
  return this.stub;
}

@Override
public MasterService.BlockingInterface getMaster() throws MasterNotRunningException {
  return getKeepAliveMasterService();
}

@Override
public MasterService.BlockingInterface getMasterAdminService()
throws IOException {
  HConnection conn = HConnectionManager.getConnection(conf);
  return conn.getMaster();
}

@Override
public MasterService.BlockingInterface getMaster() throws IOException {
  return wrappedConnection.getMaster();
}

@Override
protected String getServiceName() {
  return MasterService.getDescriptor().getName();
}

@Override
@edu.umd.cs.findbugs.annotations.SuppressWarnings("SWL_SLEEP_WITH_LOCK_HELD")
MasterService.BlockingInterface makeStub() throws MasterNotRunningException {
  return (MasterService.BlockingInterface)super.makeStub();
}

@Override
protected Object makeStub(BlockingRpcChannel channel) {
  this.stub = MasterService.newBlockingStub(channel);
  return this.stub;
}

@Override
public MasterService.BlockingInterface getMaster() throws MasterNotRunningException {
  return getKeepAliveMasterService();
}

/**
 * Returns the current active master, if available.
 * @return the active HMaster, null if none is active.
 */
public MasterService.BlockingInterface getMasterAdminService() {
  return this.hbaseCluster.getActiveMaster().getMasterRpcServices();
}

/**
 * Returns an {@link MasterService.BlockingInterface} to the active master
 */
public abstract MasterService.BlockingInterface getMasterAdminService()
throws IOException;

/**
 * Returns a {@link MasterKeepAliveConnection} to the active master
 * @deprecated internal method, do not use thru HConnection */
@Deprecated
MasterService.BlockingInterface getMaster() throws IOException;

/**
 * Returns a {@link MasterKeepAliveConnection} to the active master
 */
@Override
MasterService.BlockingInterface getMaster() throws IOException;

/**
 * Returns the current active master, if available.
 * @return the active HMaster, null if none is active.
 */
public MasterService.BlockingInterface getMasterAdminService() {
  return this.hbaseCluster.getActiveMaster().getMasterRpcServices();
}

/**
 * Returns an {@link MasterService.BlockingInterface} to the active master
 */
public abstract MasterService.BlockingInterface getMasterAdminService()
throws IOException;

/**
 * Returns a {@link MasterKeepAliveConnection} to the active master
 * @deprecated internal method, do not use thru HConnection */
@Deprecated
MasterService.BlockingInterface getMaster() throws IOException;

/**
 * Returns a {@link MasterKeepAliveConnection} to the active master
 */
@Override
MasterService.BlockingInterface getMaster() throws IOException;

/**
 * Returns an {@link MasterAdminService.BlockingInterface} to the active master
 */
public abstract MasterService.BlockingInterface getMaster()
throws IOException;

/**
 * Returns a {@link MasterKeepAliveConnection} to the active master
 */
MasterService.BlockingInterface getMaster() throws IOException;