@Override public ShutdownResponse shutdown(RpcController controller, ShutdownRequest request) throws ServiceException { LOG.info(master.getClientIdAuditPrefix() + " shutdown"); master.shutdown(); return ShutdownResponse.newBuilder().build(); }
/** * Shuts down the HBase cluster * @throws IOException if a remote or network exception occurs */ @Override public synchronized void shutdown() throws IOException { executeCallable(new MasterCallable<Void>(getConnection()) { @Override public Void call(int callTimeout) throws ServiceException { PayloadCarryingRpcController controller = rpcControllerFactory.newController(); controller.setCallTimeout(callTimeout); controller.setPriority(HConstants.HIGH_QOS); master.shutdown(controller, ShutdownRequest.newBuilder().build()); return null; } }); }
/** * Shuts down the HBase cluster * @throws IOException if a remote or network exception occurs */ @Override public synchronized void shutdown() throws IOException { executeCallable(new MasterCallable<Void>(getConnection()) { @Override public Void call(int callTimeout) throws ServiceException { master.shutdown(null,ShutdownRequest.newBuilder().build()); return null; } }); }
@Override public ShutdownResponse shutdown(RpcController controller, ShutdownRequest request) throws ServiceException { LOG.info(getClientIdAuditPrefix() + " shutdown"); shutdown(); return ShutdownResponse.newBuilder().build(); }
/** * Shuts down the HBase cluster * @throws IOException if a remote or network exception occurs */ public synchronized void shutdown() throws IOException { executeCallable(new MasterCallable<Void>(getConnection()) { @Override public Void call() throws ServiceException { master.shutdown(null,ShutdownRequest.newBuilder().build()); return null; } }); }
/** * Shuts down the HBase cluster * @throws IOException if a remote or network exception occurs */ public synchronized void shutdown() throws IOException { executeCallable(new MasterCallable<Void>(getConnection()) { @Override public Void call(int callTimeout) throws ServiceException { master.shutdown(null,ShutdownRequest.newBuilder().build()); return null; } }); }