Java 类org.apache.hadoop.hbase.protobuf.generated.AdminProtos.MergeRegionsResponse 实例源码

项目：HIndex 文件：HRegionServer.java

/**
 * Merge regions on the region server.
 *
 * @param controller the RPC controller
 * @param request the request
 * @return merge regions response
 * @throws ServiceException
 */
@Override
@QosPriority(priority = HConstants.HIGH_QOS)
public MergeRegionsResponse mergeRegions(final RpcController controller,
    final MergeRegionsRequest request) throws ServiceException {
  try {
    checkOpen();
    requestCount.increment();
    HRegion regionA = getRegion(request.getRegionA());
    HRegion regionB = getRegion(request.getRegionB());
    boolean forcible = request.getForcible();
    regionA.startRegionOperation(Operation.MERGE_REGION);
    regionB.startRegionOperation(Operation.MERGE_REGION);
    LOG.info("Receiving merging request for  " + regionA + ", " + regionB
        + ",forcible=" + forcible);
    regionA.flushcache();
    regionB.flushcache();
    compactSplitThread.requestRegionsMerge(regionA, regionB, forcible);
    return MergeRegionsResponse.newBuilder().build();
  } catch (IOException ie) {
    throw new ServiceException(ie);
  }
}

项目：PyroDB 文件：RSRpcServices.java

/**
 * Merge regions on the region server.
 *
 * @param controller the RPC controller
 * @param request the request
 * @return merge regions response
 * @throws ServiceException
 */
@Override
@QosPriority(priority = HConstants.HIGH_QOS)
public MergeRegionsResponse mergeRegions(final RpcController controller,
    final MergeRegionsRequest request) throws ServiceException {
  try {
    checkOpen();
    requestCount.increment();
    HRegion regionA = getRegion(request.getRegionA());
    HRegion regionB = getRegion(request.getRegionB());
    boolean forcible = request.getForcible();
    regionA.startRegionOperation(Operation.MERGE_REGION);
    regionB.startRegionOperation(Operation.MERGE_REGION);
    LOG.info("Receiving merging request for  " + regionA + ", " + regionB
        + ",forcible=" + forcible);
    regionA.flushcache();
    regionB.flushcache();
    regionServer.compactSplitThread.requestRegionsMerge(regionA, regionB, forcible);
    return MergeRegionsResponse.newBuilder().build();
  } catch (IOException ie) {
    throw new ServiceException(ie);
  }
}

项目：c5 文件：HRegionServer.java

/**
 * Merge regions on the region server.
 *
 * @param controller the RPC controller
 * @param request the request
 * @return merge regions response
 * @throws ServiceException
 */
@Override
@QosPriority(priority = HConstants.HIGH_QOS)
public MergeRegionsResponse mergeRegions(final RpcController controller,
    final MergeRegionsRequest request) throws ServiceException {
  try {
    checkOpen();
    requestCount.increment();
    HRegion regionA = getRegion(request.getRegionA());
    HRegion regionB = getRegion(request.getRegionB());
    boolean forcible = request.getForcible();
    regionA.startRegionOperation(Operation.MERGE_REGION);
    regionB.startRegionOperation(Operation.MERGE_REGION);
    LOG.info("Receiving merging request for  " + regionA + ", " + regionB
        + ",forcible=" + forcible);
    regionA.flushcache();
    regionB.flushcache();
    compactSplitThread.requestRegionsMerge(regionA, regionB, forcible);
    return MergeRegionsResponse.newBuilder().build();
  } catch (IOException ie) {
    throw new ServiceException(ie);
  }
}

项目：ditb 文件：MockRegionServer.java

@Override
public MergeRegionsResponse mergeRegions(RpcController controller,
    MergeRegionsRequest request) throws ServiceException {
  // TODO Auto-generated method stub
  return null;
}

项目：pbase 文件：MockRegionServer.java

@Override
public MergeRegionsResponse mergeRegions(RpcController controller,
    MergeRegionsRequest request) throws ServiceException {
  // TODO Auto-generated method stub
  return null;
}

项目：HIndex 文件：MockRegionServer.java

@Override
public MergeRegionsResponse mergeRegions(RpcController controller,
    MergeRegionsRequest request) throws ServiceException {
  // TODO Auto-generated method stub
  return null;
}

项目：PyroDB 文件：MockRegionServer.java

@Override
public MergeRegionsResponse mergeRegions(RpcController controller,
    MergeRegionsRequest request) throws ServiceException {
  // TODO Auto-generated method stub
  return null;
}

项目：c5 文件：MockRegionServer.java

@Override
public MergeRegionsResponse mergeRegions(RpcController controller,
    MergeRegionsRequest request) throws ServiceException {
  // TODO Auto-generated method stub
  return null;
}