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

项目：ditb 文件：MasterRpcServices.java

@Override
public SetBalancerRunningResponse setBalancerRunning(RpcController c,
    SetBalancerRunningRequest req) throws ServiceException {
  try {
    master.checkInitialized();
    boolean prevValue = (req.getSynchronous())?
      synchronousBalanceSwitch(req.getOn()) : master.balanceSwitch(req.getOn());
    return SetBalancerRunningResponse.newBuilder().setPrevBalanceValue(prevValue).build();
  } catch (IOException ioe) {
    throw new ServiceException(ioe);
  }
}

项目：pbase 文件：MasterRpcServices.java

@Override
public SetBalancerRunningResponse setBalancerRunning(RpcController c,
    SetBalancerRunningRequest req) throws ServiceException {
  try {
    master.checkInitialized();
    boolean prevValue = (req.getSynchronous())?
      synchronousBalanceSwitch(req.getOn()) : master.balanceSwitch(req.getOn());
    return SetBalancerRunningResponse.newBuilder().setPrevBalanceValue(prevValue).build();
  } catch (IOException ioe) {
    throw new ServiceException(ioe);
  }
}

项目：HIndex 文件：HMaster.java

@Override
public SetBalancerRunningResponse setBalancerRunning(
    RpcController controller, SetBalancerRunningRequest req) throws ServiceException {
  try {
    boolean prevValue = (req.getSynchronous())?
      synchronousBalanceSwitch(req.getOn()):balanceSwitch(req.getOn());
    return SetBalancerRunningResponse.newBuilder().setPrevBalanceValue(prevValue).build();
  } catch (IOException ioe) {
    throw new ServiceException(ioe);
  }
}

项目：PyroDB 文件：MasterRpcServices.java

@Override
public SetBalancerRunningResponse setBalancerRunning(RpcController c,
    SetBalancerRunningRequest req) throws ServiceException {
  try {
    master.checkInitialized();
    boolean prevValue = (req.getSynchronous())?
      synchronousBalanceSwitch(req.getOn()) : master.balanceSwitch(req.getOn());
    return SetBalancerRunningResponse.newBuilder().setPrevBalanceValue(prevValue).build();
  } catch (IOException ioe) {
    throw new ServiceException(ioe);
  }
}

项目：c5 文件：HMaster.java

@Override
public SetBalancerRunningResponse setBalancerRunning(
    RpcController controller, SetBalancerRunningRequest req) throws ServiceException {
  try {
    boolean prevValue = (req.getSynchronous())?
      synchronousBalanceSwitch(req.getOn()):balanceSwitch(req.getOn());
    return SetBalancerRunningResponse.newBuilder().setPrevBalanceValue(prevValue).build();
  } catch (IOException ioe) {
    throw new ServiceException(ioe);
  }
}