/** * @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); } }
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 MasterService.BlockingInterface makeStub() throws IOException { return (MasterService.BlockingInterface) super.makeStub(); }
@Override public MasterService.BlockingInterface getMaster() throws IOException { HConnection conn = HConnectionManager.getConnection(conf); return conn.getMaster(); }
@Override @edu.umd.cs.findbugs.annotations.SuppressWarnings("SWL_SLEEP_WITH_LOCK_HELD") MasterService.BlockingInterface makeStub() throws MasterNotRunningException { return (MasterService.BlockingInterface)super.makeStub(); }
@Override public MasterService.BlockingInterface getMasterAdminService() throws IOException { HConnection conn = HConnectionManager.getConnection(conf); return conn.getMaster(); }
/** * 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;