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

Region.getStore介绍

[英]Return the Store for the given family

Use with caution. Exposed for use of fixup utilities.
[中]返回给定家庭的商店
小心使用。暴露在外以供安装工具使用。

代码示例

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

public void finish(Map<byte[], List<Cell>> familyMaps) {
 if (!isEnable()) {
  return;
 }
 for (Map.Entry<byte[], List<Cell>> e : familyMaps.entrySet()) {
  Store store = this.region.getStore(e.getKey());
  if (store == null || e.getValue() == null) {
   continue;
  }
  if (e.getValue().size() > this.parallelPutToStoreThreadLimitCheckMinColumnCount) {
   AtomicInteger counter = preparePutToStoreMap.get(e.getKey());
   // preparePutToStoreMap will be cleared when changing the configuration, so it may turn
   // into a negative value. It will be not accuracy in a short time, it's a trade-off for
   // performance.
   if (counter != null && counter.decrementAndGet() < 0) {
    counter.incrementAndGet();
   }
  }
 }
}

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

for (HStoreFile sf : (Collection<HStoreFile>)region.getStore(familyNameBytes).getStorefiles()) {
 synchronized (sf) {
  if (count < refSFCount) {
assertEquals(1, region.getStoreFileList(new byte[][]{familyNameBytes}).size());
assertEquals(refSFCount+1,
 ((HStore)region.getStore(familyNameBytes)).getStoreEngine().getStoreFileManager()
   .getCompactedfiles().size());
assertEquals(1, region.getStoreFileList(new byte[][]{familyNameBytes}).size());
assertEquals(0,
  ((HStore)region.getStore(familyNameBytes)).getStoreEngine().getStoreFileManager()
    .getCompactedfiles().size());

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

Store store = this.region.getStore(e.getKey());
if (store == null || e.getValue() == null) {
 continue;

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

HStoreFile hsf = ((Collection<HStoreFile>)region.getStore(familyNameBytes).getStorefiles())
  .iterator().next();
long readPt = ((HRegion)region).getReadPoint(IsolationLevel.READ_COMMITTED);

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

private void verifyInMemoryFlushSize(Region region) {
 assertEquals(
  ((CompactingMemStore) ((HStore)region.getStore(FAMILY1)).memstore).getInmemoryFlushSize(),
  ((CompactingMemStore) ((HStore)region.getStore(FAMILY3)).memstore).getInmemoryFlushSize());
}

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

for (HStoreFile sf : (Collection<HStoreFile>)region.getStore(familyNameBytes).getStorefiles()) {
 synchronized (sf) {
  if (count < refSFCount) {
assertEquals(1, region.getStoreFileList(new byte[][]{familyNameBytes}).size());
assertEquals(refSFCount+1,
 ((HStore)region.getStore(familyNameBytes)).getStoreEngine().getStoreFileManager()
   .getCompactedfiles().size());
assertEquals(1, region.getStoreFileList(new byte[][]{familyNameBytes}).size());
assertEquals(0,
  ((HStore)region.getStore(familyNameBytes)).getStoreEngine().getStoreFileManager()
    .getCompactedfiles().size());

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

public int getNumHFilesForRS(final HRegionServer rs, final TableName tableName,
               final byte[] family) {
 int numHFiles = 0;
 for (Region region : rs.getRegions(tableName)) {
  numHFiles += region.getStore(family).getStorefilesCount();
 }
 return numHFiles;
}

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

HStoreFile hsf = ((Collection<HStoreFile>)region.getStore(familyNameBytes).getStorefiles())
  .iterator().next();
long readPt = ((HRegion)region).getReadPoint(IsolationLevel.READ_COMMITTED);

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

byte[] family = "testF1".getBytes();
when(mockRegion.getStore(family)).thenReturn(mockStore1);
when(mockRegion.getRegionInfo()).thenReturn(mockRegionInfo);
when(mockRegionInfo.getRegionNameAsString()).thenReturn("test_region_1");

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

cf1StoreFileCount = region.getStore(FAMILY1).getStorefilesCount();
 cf2StoreFileCount = region.getStore(FAMILY2).getStorefilesCount();
 cf3StoreFileCount = region.getStore(FAMILY3).getStorefilesCount();
} finally {
 TEST_UTIL.shutdownMiniCluster();
 cf1StoreFileCount1 = region.getStore(FAMILY1).getStorefilesCount();
 cf2StoreFileCount1 = region.getStore(FAMILY2).getStorefilesCount();
 cf3StoreFileCount1 = region.getStore(FAMILY3).getStorefilesCount();
} finally {
 TEST_UTIL.shutdownMiniCluster();

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

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

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

secondaryRegion.getStore(f).refreshStoreFiles();
Assert.assertEquals(3, secondaryRegion.getStore(f).getStorefilesCount());
for (HStoreFile sf : ((HStore) secondaryRegion.getStore(f)).getStorefiles()) {

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

public void testCompactionConfigurationOnlineChange() throws IOException {
 String strPrefix = "hbase.hstore.compaction.";
 Store s = r1.getStore(COLUMN_FAMILY1);
 if (!(s instanceof HStore)) {
  LOG.error("Can't test the compaction configuration of HStore class. "

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

private void verifyInMemoryFlushSize(Region region) {
 assertEquals(
  ((CompactingMemStore) ((HStore)region.getStore(FAMILY1)).memstore).getInmemoryFlushSize(),
  ((CompactingMemStore) ((HStore)region.getStore(FAMILY3)).memstore).getInmemoryFlushSize());
}

代码示例来源：origin: org.apache.phoenix/phoenix-core

private boolean checkForReferenceFiles() {
 if(!ScanUtil.isLocalIndex(scan)) return false;
 for (byte[] family : scan.getFamilies()) {
  if (getRegion().getStore(family).hasReferences()) {
   return true;
  }
 }
 return false;
}

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

public int getNumHFilesForRS(final HRegionServer rs, final TableName tableName,
               final byte[] family) {
 int numHFiles = 0;
 for (Region region : rs.getRegions(tableName)) {
  numHFiles += region.getStore(family).getStorefilesCount();
 }
 return numHFiles;
}

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

byte[] family = "testF1".getBytes();
when(mockRegion.getStore(family)).thenReturn(mockStore1);
when(mockRegion.getRegionInfo()).thenReturn(mockRegionInfo);
when(mockRegionInfo.getRegionNameAsString()).thenReturn("test_region_1");

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

if (request.hasFamily()) {
 family = request.getFamily().toByteArray();
 store = region.getStore(family);
 if (store == null) {
  throw new ServiceException(new IOException("column family " + Bytes.toString(family)

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

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

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

secondaryRegion.getStore(f).refreshStoreFiles();
Assert.assertEquals(3, secondaryRegion.getStore(f).getStorefilesCount());
for (HStoreFile sf : ((HStore) secondaryRegion.getStore(f)).getStorefiles()) {