org.apache.hadoop.hbase.regionserver.Store.getColumnFamilyName()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(12.5k)|赞(0)|评价(0)|浏览(160)

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

Store.getColumnFamilyName介绍

暂无

代码示例

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

|| preparePutCount > this.parallelPreparePutToStoreThreadLimit) {
tooBusyStore = (tooBusyStore == null ?
  store.getColumnFamilyName() :
  tooBusyStore + "," + store.getColumnFamilyName());
LOG.trace(store.getColumnFamilyName() + ": preparePutCount=" + preparePutCount
  + "; currentParallelPutCount=" + store.getCurrentParallelPutCount());

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

@Test
public void testRequestOnRegion() throws IOException, InterruptedException {
 Tracker tracker = new Tracker();
 TRACKER = tracker;
 region.requestCompaction("test", Store.PRIORITY_USER, false, tracker);
 tracker.await();
 assertEquals(1, tracker.notExecutedStores.size());
 assertEquals(Bytes.toString(CF2),
  tracker.notExecutedStores.get(0).getFirst().getColumnFamilyName());
 assertThat(tracker.notExecutedStores.get(0).getSecond(),
  containsString("compaction request was cancelled"));
 assertEquals(1, tracker.beforeExecuteStores.size());
 assertEquals(Bytes.toString(CF1), tracker.beforeExecuteStores.get(0).getColumnFamilyName());
 assertEquals(1, tracker.afterExecuteStores.size());
 assertEquals(Bytes.toString(CF1), tracker.afterExecuteStores.get(0).getColumnFamilyName());
}

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

@Test
public void testRequestOnStore() throws IOException, InterruptedException {
 Tracker tracker = new Tracker();
 TRACKER = tracker;
 region.requestCompaction(CF1, "test", Store.PRIORITY_USER, false, tracker);
 tracker.await();
 assertTrue(tracker.notExecutedStores.isEmpty());
 assertEquals(1, tracker.beforeExecuteStores.size());
 assertEquals(Bytes.toString(CF1), tracker.beforeExecuteStores.get(0).getColumnFamilyName());
 assertEquals(1, tracker.afterExecuteStores.size());
 assertEquals(Bytes.toString(CF1), tracker.afterExecuteStores.get(0).getColumnFamilyName());
 tracker = new Tracker();
 TRACKER = tracker;
 region.requestCompaction(CF2, "test", Store.PRIORITY_USER, false, tracker);
 tracker.await();
 assertEquals(1, tracker.notExecutedStores.size());
 assertEquals(Bytes.toString(CF2),
  tracker.notExecutedStores.get(0).getFirst().getColumnFamilyName());
 assertThat(tracker.notExecutedStores.get(0).getSecond(),
  containsString("compaction request was cancelled"));
 assertTrue(tracker.beforeExecuteStores.isEmpty());
 assertTrue(tracker.afterExecuteStores.isEmpty());
}

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

@Test
 public void testSpaceQuotaViolation() throws IOException, InterruptedException {
  region.getRegionServerServices().getRegionServerSpaceQuotaManager().enforceViolationPolicy(NAME,
   new SpaceQuotaSnapshot(new SpaceQuotaStatus(SpaceViolationPolicy.NO_WRITES_COMPACTIONS), 10L,
     100L));
  Tracker tracker = new Tracker();
  TRACKER = tracker;
  region.requestCompaction("test", Store.PRIORITY_USER, false, tracker);
  tracker.await();
  assertEquals(2, tracker.notExecutedStores.size());
  tracker.notExecutedStores.sort((p1, p2) -> p1.getFirst().getColumnFamilyName()
    .compareTo(p2.getFirst().getColumnFamilyName()));

  assertEquals(Bytes.toString(CF1),
   tracker.notExecutedStores.get(0).getFirst().getColumnFamilyName());
  assertThat(tracker.notExecutedStores.get(0).getSecond(),
   containsString("space quota violation"));

  assertEquals(Bytes.toString(CF2),
   tracker.notExecutedStores.get(1).getFirst().getColumnFamilyName());
  assertThat(tracker.notExecutedStores.get(1).getSecond(),
   containsString("space quota violation"));

  assertTrue(tracker.beforeExecuteStores.isEmpty());
  assertTrue(tracker.afterExecuteStores.isEmpty());
 }
}

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

when(mockStore1.getColumnFamilyName()).thenReturn("test_Family_1");

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

List<? extends Store> stores = region.getStores();
for (Store store : stores) {
 String cf = store.getColumnFamilyName();
 Collection<? extends StoreFile> storeFiles = store.getStorefiles(); 
out.write("\n\n       <h3>Column Family: ");

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

@Override
public InternalScanner createCompactionScanner(RegionCoprocessorEnvironment env,
                        Store store, InternalScanner delegate) {
  ImmutableBytesPtr cfKey =
      new ImmutableBytesPtr(store.getColumnFamilyDescriptor().getName());
  LOG.info("StatisticsScanner created for table: "
      + tableName + " CF: " + store.getColumnFamilyName());
  return new StatisticsScanner(this, statsWriter, env, delegate, cfKey);
}

代码示例来源：origin: co.cask.hbase/hbase

@Override
public String toString() {
 return getColumnFamilyName();
}

代码示例来源：origin: org.apache.omid/omid-hbase-shims-hbase1.x

public static boolean OmidCompactionEnabled(ObserverContext<RegionCoprocessorEnvironment> env,
               Store store,
               String cfFlagValue) {
  HTableDescriptor desc = env.getEnvironment().getRegion().getTableDesc();
  HColumnDescriptor famDesc
      = desc.getFamily(Bytes.toBytes(store.getColumnFamilyName()));
  return Boolean.valueOf(famDesc.getValue(cfFlagValue));
}

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

@Override
protected boolean shouldSplit() {
 if (region.shouldForceSplit()) return true;
 boolean foundABigStore = false;
 // Get count of regions that have the same common table as this.region
 int tableRegionsCount = getCountOfCommonTableRegions();
 // Get size to check
 long sizeToCheck = getSizeToCheck(tableRegionsCount);
 for (Store store : region.getStores().values()) {
  // If any of the stores is unable to split (eg they contain reference files)
  // then don't split
  if ((!store.canSplit())) {
   return false;
  }
  // Mark if any store is big enough
  long size = store.getSize();
  if (size > sizeToCheck) {
   LOG.debug("ShouldSplit because " + store.getColumnFamilyName() +
    " size=" + size + ", sizeToCheck=" + sizeToCheck +
    ", regionsWithCommonTable=" + tableRegionsCount);
   foundABigStore = true;
   break;
  }
 }
 return foundABigStore;
}

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

@Test
public void testRequestOnRegion() throws IOException, InterruptedException {
 Tracker tracker = new Tracker();
 TRACKER = tracker;
 region.requestCompaction("test", Store.PRIORITY_USER, false, tracker);
 tracker.await();
 assertEquals(1, tracker.notExecutedStores.size());
 assertEquals(Bytes.toString(CF2),
  tracker.notExecutedStores.get(0).getFirst().getColumnFamilyName());
 assertThat(tracker.notExecutedStores.get(0).getSecond(),
  containsString("compaction request was cancelled"));
 assertEquals(1, tracker.beforeExecuteStores.size());
 assertEquals(Bytes.toString(CF1), tracker.beforeExecuteStores.get(0).getColumnFamilyName());
 assertEquals(1, tracker.afterExecuteStores.size());
 assertEquals(Bytes.toString(CF1), tracker.afterExecuteStores.get(0).getColumnFamilyName());
}

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

private boolean shouldFlush(Store store) {
 if (store.getMemStoreSize() > this.flushSizeLowerBound) {
  if (LOG.isDebugEnabled()) {
   LOG.debug("Flush Column Family " + store.getColumnFamilyName() + " of " +
    region.getRegionInfo().getEncodedName() + " because memstoreSize=" +
    store.getMemStoreSize() + " > lower bound=" + this.flushSizeLowerBound);
  }
  return true;
 }
 return region.shouldFlushStore(store);
}

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

byte[] cf = Bytes.toBytes(store.getColumnFamilyName());
if (stores.get(cf) != store) {
 LOG.warn("Store " + store.getColumnFamilyName() + " on region " + this
   + " has been re-instantiated, cancel this compaction request. "
   + " It may be caused by the roll back of split transaction");

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

@Test
public void testRequestOnStore() throws IOException, InterruptedException {
 Tracker tracker = new Tracker();
 TRACKER = tracker;
 region.requestCompaction(CF1, "test", Store.PRIORITY_USER, false, tracker);
 tracker.await();
 assertTrue(tracker.notExecutedStores.isEmpty());
 assertEquals(1, tracker.beforeExecuteStores.size());
 assertEquals(Bytes.toString(CF1), tracker.beforeExecuteStores.get(0).getColumnFamilyName());
 assertEquals(1, tracker.afterExecuteStores.size());
 assertEquals(Bytes.toString(CF1), tracker.afterExecuteStores.get(0).getColumnFamilyName());
 tracker = new Tracker();
 TRACKER = tracker;
 region.requestCompaction(CF2, "test", Store.PRIORITY_USER, false, tracker);
 tracker.await();
 assertEquals(1, tracker.notExecutedStores.size());
 assertEquals(Bytes.toString(CF2),
  tracker.notExecutedStores.get(0).getFirst().getColumnFamilyName());
 assertThat(tracker.notExecutedStores.get(0).getSecond(),
  containsString("compaction request was cancelled"));
 assertTrue(tracker.beforeExecuteStores.isEmpty());
 assertTrue(tracker.afterExecuteStores.isEmpty());
}

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

@Test
 public void testSpaceQuotaViolation() throws IOException, InterruptedException {
  region.getRegionServerServices().getRegionServerSpaceQuotaManager().enforceViolationPolicy(NAME,
   new SpaceQuotaSnapshot(new SpaceQuotaStatus(SpaceViolationPolicy.NO_WRITES_COMPACTIONS), 10L,
     100L));
  Tracker tracker = new Tracker();
  TRACKER = tracker;
  region.requestCompaction("test", Store.PRIORITY_USER, false, tracker);
  tracker.await();
  assertEquals(2, tracker.notExecutedStores.size());
  tracker.notExecutedStores.sort((p1, p2) -> p1.getFirst().getColumnFamilyName()
    .compareTo(p2.getFirst().getColumnFamilyName()));

  assertEquals(Bytes.toString(CF1),
   tracker.notExecutedStores.get(0).getFirst().getColumnFamilyName());
  assertThat(tracker.notExecutedStores.get(0).getSecond(),
   containsString("space quota violation"));

  assertEquals(Bytes.toString(CF2),
   tracker.notExecutedStores.get(1).getFirst().getColumnFamilyName());
  assertThat(tracker.notExecutedStores.get(1).getSecond(),
   containsString("space quota violation"));

  assertTrue(tracker.beforeExecuteStores.isEmpty());
  assertTrue(tracker.afterExecuteStores.isEmpty());
 }
}

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

when(mockStore1.getColumnFamilyName()).thenReturn("test_Family_1");

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

@Override
protected boolean shouldSplit() {
 boolean force = region.shouldForceSplit();
 boolean foundABigStore = false;
 // Get count of regions that have the same common table as this.region
 int tableRegionsCount = getCountOfCommonTableRegions();
 // Get size to check
 long sizeToCheck = getSizeToCheck(tableRegionsCount);
 for (Store store : region.getStores()) {
  // If any of the stores is unable to split (eg they contain reference files)
  // then don't split
  if (!store.canSplit()) {
   return false;
  }
  // Mark if any store is big enough
  long size = store.getSize();
  if (size > sizeToCheck) {
   LOG.debug("ShouldSplit because " + store.getColumnFamilyName() + " size=" + size
        + ", sizeToCheck=" + sizeToCheck + ", regionsWithCommonTable="
        + tableRegionsCount);
   foundABigStore = true;
  }
 }
 return foundABigStore | force;
}

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

if (earliest > 0 && earliest + flushPerChanges < mvcc.getReadPoint()) {
 if (LOG.isDebugEnabled()) {
  LOG.debug("Flush column family " + store.getColumnFamilyName() + " of " +
   getRegionInfo().getEncodedName() + " because unflushed sequenceid=" + earliest +
   " is > " + this.flushPerChanges + " from current=" + mvcc.getReadPoint());
if (store.timeOfOldestEdit() < now - this.flushCheckInterval) {
 if (LOG.isDebugEnabled()) {
  LOG.debug("Flush column family: " + store.getColumnFamilyName() + " of " +
   getRegionInfo().getEncodedName() + " because time of oldest edit=" +
    store.timeOfOldestEdit() + " is > " + this.flushCheckInterval + " from now =" + now);

内容来源于网络，如有侵权，请联系作者删除！

store

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    Store类方法

    • 蜀ICP备2022004421号-2 NULL123 https://www.null123.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com