本文整理汇总了Java中org.apache.hadoop.hbase.protobuf.generated.AdminProtos.SplitRegionResponse类的典型用法代码示例。如果您正苦于以下问题：Java SplitRegionResponse类的具体用法？Java SplitRegionResponse怎么用？Java SplitRegionResponse使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
SplitRegionResponse类属于org.apache.hadoop.hbase.protobuf.generated.AdminProtos包，在下文中一共展示了SplitRegionResponse类的6个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: splitRegion
import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.SplitRegionResponse; //导入依赖的package包/类
/**
* 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);
}
}
开发者ID:tenggyut，项目名称:HIndex，代码行数:30，代码来源:HRegionServer.java
示例2: splitRegion
import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.SplitRegionResponse; //导入依赖的package包/类
/**
* 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);
}
}
开发者ID:daidong，项目名称:DominoHBase，代码行数:29，代码来源:HRegionServer.java
示例3: splitRegion
import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.SplitRegionResponse; //导入依赖的package包/类
/**
* 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);
}
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:43，代码来源:RSRpcServices.java
示例4: splitRegion
import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.SplitRegionResponse; //导入依赖的package包/类
/**
* 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);
}
}
开发者ID:grokcoder，项目名称:pbase，代码行数:35，代码来源:RSRpcServices.java
示例5: splitRegion
import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.SplitRegionResponse; //导入依赖的package包/类
/**
* 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);
}
}
开发者ID:shenli-uiuc，项目名称:PyroDB，代码行数:35，代码来源:RSRpcServices.java
示例6: splitRegion
import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.SplitRegionResponse; //导入依赖的package包/类
@Override
public SplitRegionResponse splitRegion(RpcController controller,
SplitRegionRequest request) throws ServiceException {
// TODO Auto-generated method stub
return null;
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:7，代码来源:MockRegionServer.java
注：本文中的org.apache.hadoop.hbase.protobuf.generated.AdminProtos.SplitRegionResponse类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论