本文整理了Java中org.apache.hadoop.hbase.regionserver.Store.getRegionInfo()
方法的一些代码示例,展示了Store.getRegionInfo()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Store.getRegionInfo()
方法的具体详情如下:
包路径:org.apache.hadoop.hbase.regionserver.Store
类名称:Store
方法名:getRegionInfo
暂无
代码示例来源:origin: apache/hbase
@Override
public void refreshHFiles(RpcController controller, RefreshHFilesProtos.RefreshHFilesRequest request,
RpcCallback<RefreshHFilesProtos.RefreshHFilesResponse> done) {
try {
for (Store store : env.getRegion().getStores()) {
LOG.debug("Refreshing HFiles for region: " + store.getRegionInfo().getRegionNameAsString() +
" and store: " + store.getColumnFamilyName() + "class:" + store.getClass());
store.refreshStoreFiles();
}
} catch (IOException ioe) {
LOG.error("Exception while trying to refresh store files: ", ioe);
CoprocessorRpcUtils.setControllerException(controller, ioe);
}
done.run(RefreshHFilesProtos.RefreshHFilesResponse.getDefaultInstance());
}
代码示例来源:origin: harbby/presto-connectors
private String generateCompactionName() {
int counter;
for (;;) {
counter = NAME_COUNTER.get();
int next = counter == Integer.MAX_VALUE ? 0 : counter + 1;
if (NAME_COUNTER.compareAndSet(counter, next)) {
break;
}
}
return store.getRegionInfo().getRegionNameAsString() + "#"
+ store.getFamily().getNameAsString() + "#" + counter;
}
/**
代码示例来源:origin: com.aliyun.hbase/alihbase-examples
@Override
public void refreshHFiles(RpcController controller, RefreshHFilesProtos.RefreshHFilesRequest request,
RpcCallback<RefreshHFilesProtos.RefreshHFilesResponse> done) {
try {
for (Store store : env.getRegion().getStores()) {
LOG.debug("Refreshing HFiles for region: " + store.getRegionInfo().getRegionNameAsString() +
" and store: " + store.getColumnFamilyName() + "class:" + store.getClass());
store.refreshStoreFiles();
}
} catch (IOException ioe) {
LOG.error("Exception while trying to refresh store files: ", ioe);
CoprocessorRpcUtils.setControllerException(controller, ioe);
}
done.run(RefreshHFilesProtos.RefreshHFilesResponse.getDefaultInstance());
}
代码示例来源:origin: harbby/presto-connectors
writer = null;
throw new InterruptedIOException("Aborting compaction of store " + store +
" in region " + store.getRegionInfo().getRegionNameAsString() +
" because it was interrupted.");
代码示例来源:origin: harbby/presto-connectors
if (!finished) {
throw new InterruptedIOException( "Aborting compaction of store " + store +
" in region " + store.getRegionInfo().getRegionNameAsString() +
" because it was interrupted.");
内容来源于网络,如有侵权,请联系作者删除!