本文整理了Java中org.apache.hadoop.hbase.regionserver.Store.refreshStoreFiles()方法的一些代码示例，展示了Store.refreshStoreFiles()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Store.refreshStoreFiles()方法的具体详情如下：
包路径：org.apache.hadoop.hbase.regionserver.Store
类名称：Store
方法名：refreshStoreFiles

Store.refreshStoreFiles介绍

[英]Checks the underlying store files, and opens the files that have not been opened, and removes the store file readers for store files no longer available. Mainly used by secondary region replicas to keep up to date with the primary region files.
[中]检查基础存储文件，打开尚未打开的文件，并删除不再可用的存储文件的存储文件读取器。主要由次区域副本使用，以与主区域文件保持同步。

代码示例

代码示例来源：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: apache/hbase

store.refreshStoreFiles();

代码示例来源：origin: apache/hbase

secondaryRegion.getStore(f).refreshStoreFiles();
Assert.assertEquals(3, secondaryRegion.getStore(f).getStorefilesCount());

代码示例来源：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

store.refreshStoreFiles();

代码示例来源：origin: harbby/presto-connectors

store.refreshStoreFiles();

代码示例来源：origin: harbby/presto-connectors

List<String> storeFiles = storeDescriptor.getStoreFileList();
try {
 store.refreshStoreFiles(storeFiles); // replace the files with the new ones
} catch (FileNotFoundException ex) {
 LOG.warn(getRegionInfo().getEncodedName() + " : "

代码示例来源：origin: org.apache.hbase/hbase-server

secondaryRegion.getStore(f).refreshStoreFiles();
Assert.assertEquals(3, secondaryRegion.getStore(f).getStorefilesCount());