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

/**
 * Split a region on the region server.
 *
 * @param controller the RPC controller
 * @param request the request
 * @throws ServiceException
 */
@Override
@QosPriority(priority=HConstants.HIGH_QOS)
public SplitRegionResponse splitRegion(final RpcController controller,
    final SplitRegionRequest request) throws ServiceException {
  try {
    checkOpen();
    requestCount.increment();
    HRegion region = getRegion(request.getRegion());
    region.startRegionOperation(Operation.SPLIT_REGION);
    LOG.info("Splitting " + region.getRegionNameAsString());
    region.flushcache();
    byte[] splitPoint = null;
    if (request.hasSplitPoint()) {
      splitPoint = request.getSplitPoint().toByteArray();
    }
    region.forceSplit(splitPoint);
    compactSplitThread.requestSplit(region, region.checkSplit());
    return SplitRegionResponse.newBuilder().build();
  } catch (IOException ie) {
    throw new ServiceException(ie);
  }
}

/**
 * Split a region on the region server.
 *
 * @param controller the RPC controller
 * @param request the request
 * @throws ServiceException
 */
@Override
@QosPriority(priority=HConstants.HIGH_QOS)
public SplitRegionResponse splitRegion(final RpcController controller,
    final SplitRegionRequest request) throws ServiceException {
  try {
    checkOpen();
    requestCount.increment();
    HRegion region = getRegion(request.getRegion());
    region.startRegionOperation(Operation.SPLIT_REGION);
    LOG.info("Splitting " + region.getRegionNameAsString());
    region.flushcache();
    byte[] splitPoint = null;
    if (request.hasSplitPoint()) {
      splitPoint = request.getSplitPoint().toByteArray();
    }
    region.forceSplit(splitPoint);
    compactSplitThread.requestSplit(region, region.checkSplit());
    return SplitRegionResponse.newBuilder().build();
  } catch (IOException ie) {
    throw new ServiceException(ie);
  }
}

/**
 * Split a region on the region server.
 *
 * @param controller the RPC controller
 * @param request the request
 * @throws ServiceException
 */
@Override
@QosPriority(priority=HConstants.HIGH_QOS)
public SplitRegionResponse splitRegion(final RpcController controller,
    final SplitRegionRequest request) throws ServiceException {
  try {
    checkOpen();
    requestCount.increment();
    HRegion region = getRegion(request.getRegion());
    LOG.info("Splitting " + region.getRegionNameAsString());
    region.flushcache();
    byte[] splitPoint = null;
    if (request.hasSplitPoint()) {
      splitPoint = request.getSplitPoint().toByteArray();
    }
    region.forceSplit(splitPoint);
    compactSplitThread.requestSplit(region, region.checkSplit());
    return SplitRegionResponse.newBuilder().build();
  } catch (IOException ie) {
    throw new ServiceException(ie);
  }
}

/**
 * Split a region on the region server.
 *
 * @param controller the RPC controller
 * @param request the request
 * @throws ServiceException
 */
@Override
@QosPriority(priority=HConstants.ADMIN_QOS)
public SplitRegionResponse splitRegion(final RpcController controller,
    final SplitRegionRequest request) throws ServiceException {
  try {
    checkOpen();
    requestCount.increment();
    Region region = getRegion(request.getRegion());
    region.startRegionOperation(Operation.SPLIT_REGION);
    if (region.getRegionInfo().getReplicaId() != HRegionInfo.DEFAULT_REPLICA_ID) {
      throw new IOException("Can't split replicas directly. "
          + "Replicas are auto-split when their primary is split.");
    }
    LOG.info("Splitting " + region.getRegionInfo().getRegionNameAsString());
    long startTime = EnvironmentEdgeManager.currentTime();
    FlushResult flushResult = region.flush(true);
    if (flushResult.isFlushSucceeded()) {
      long endTime = EnvironmentEdgeManager.currentTime();
      regionServer.metricsRegionServer.updateFlushTime(endTime - startTime);
    }
    byte[] splitPoint = null;
    if (request.hasSplitPoint()) {
      splitPoint = request.getSplitPoint().toByteArray();
    }
    ((HRegion)region).forceSplit(splitPoint);
    regionServer.compactSplitThread.requestSplit(region, ((HRegion)region).checkSplit(),
      RpcServer.getRequestUser());
    return SplitRegionResponse.newBuilder().build();
  } catch (DroppedSnapshotException ex) {
    regionServer.abort("Replay of WAL required. Forcing server shutdown", ex);
    throw new ServiceException(ex);
  } catch (IOException ie) {
    throw new ServiceException(ie);
  }
}

/**
 * Split a region on the region server.
 *
 * @param controller the RPC controller
 * @param request    the request
 * @throws ServiceException
 */
@Override
@QosPriority(priority = HConstants.ADMIN_QOS)
public SplitRegionResponse splitRegion(final RpcController controller,
                                       final SplitRegionRequest request) throws ServiceException {
    try {
        checkOpen();
        requestCount.increment();
        HRegion region = getRegion(request.getRegion());
        region.startRegionOperation(Operation.SPLIT_REGION);
        LOG.info("Splitting " + region.getRegionNameAsString());
        long startTime = EnvironmentEdgeManager.currentTime();
        HRegion.FlushResult flushResult = region.flushcache();
        if (flushResult.isFlushSucceeded()) {
            long endTime = EnvironmentEdgeManager.currentTime();
            regionServer.metricsRegionServer.updateFlushTime(endTime - startTime);
        }
        byte[] splitPoint = null;
        if (request.hasSplitPoint()) {
            splitPoint = request.getSplitPoint().toByteArray();
        }
        region.forceSplit(splitPoint);
        regionServer.compactSplitThread.requestSplit(region, region.checkSplit());
        return SplitRegionResponse.newBuilder().build();
    } catch (IOException ie) {
        throw new ServiceException(ie);
    }
}

/**
 * Split a region on the region server.
 *
 * @param controller the RPC controller
 * @param request the request
 * @throws ServiceException
 */
@Override
@QosPriority(priority=HConstants.HIGH_QOS)
public SplitRegionResponse splitRegion(final RpcController controller,
    final SplitRegionRequest request) throws ServiceException {
  // Shen Li: add a reuseFile field to request
  try {
    checkOpen();
    requestCount.increment();
    HRegion region = getRegion(request.getRegion());
    boolean reuseFile = request.getReuseFile();
    // TODO: should not ask client to provide dest hostnames
    // do it in SplitRequest
    region.startRegionOperation(Operation.SPLIT_REGION);
    LOG.info("Shen Li: Splitting " + region.getRegionNameAsString());
    region.flushcache();
    byte[] splitPoint = null;
    if (request.hasSplitPoint()) {
      splitPoint = request.getSplitPoint().toByteArray();
    }
    region.forceSplit(splitPoint);
    regionServer.compactSplitThread
      .requestSplit(region, region.checkSplit(), reuseFile);
    return SplitRegionResponse.newBuilder().build();
  } catch (IOException ie) {
    throw new ServiceException(ie);
  }
}

@Override
public SplitRegionResponse splitRegion(RpcController controller,
    SplitRegionRequest request) throws ServiceException {
  // TODO Auto-generated method stub
  return null;
}

@Override
public SplitRegionResponse splitRegion(RpcController controller,
    SplitRegionRequest request) throws ServiceException {
  // TODO Auto-generated method stub
  return null;
}

@Override
public SplitRegionResponse splitRegion(RpcController controller,
    SplitRegionRequest request) throws ServiceException {
  // TODO Auto-generated method stub
  return null;
}

@Override
public SplitRegionResponse splitRegion(RpcController controller,
    SplitRegionRequest request) throws ServiceException {
  // TODO Auto-generated method stub
  return null;
}

@Override
public SplitRegionResponse splitRegion(RpcController controller,
    SplitRegionRequest request) throws ServiceException {
  // TODO Auto-generated method stub
  return null;
}

@Override
public SplitRegionResponse splitRegion(RpcController controller,
    SplitRegionRequest request) throws ServiceException {
  // TODO Auto-generated method stub
  return null;
}