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

x33g5p2x  于2022-01-20 转载在 其他  
字(17.7k)|赞(0)|评价(0)|浏览(213)

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

HStore.getSize介绍

暂无

代码示例

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

  1. /**
  2.  * @return the key at which the region should be split, or null
  3.  * if it cannot be split. This will only be called if shouldSplit
  4.  * previously returned true.
  5.  */
  6. protected byte[] getSplitPoint() {
  7.  byte[] explicitSplitPoint = this.region.getExplicitSplitPoint();
  8.  if (explicitSplitPoint != null) {
  9.   return explicitSplitPoint;
  10.  }
  11.  List<HStore> stores = region.getStores();
  12.  byte[] splitPointFromLargestStore = null;
  13.  long largestStoreSize = 0;
  14.  for (HStore s : stores) {
  15.   Optional<byte[]> splitPoint = s.getSplitPoint();
  16.   // Store also returns null if it has references as way of indicating it is not splittable
  17.   long storeSize = s.getSize();
  18.   if (splitPoint.isPresent() && largestStoreSize < storeSize) {
  19.    splitPointFromLargestStore = splitPoint.get();
  20.    largestStoreSize = storeSize;
  21.   }
  22.  }
  23.  return splitPointFromLargestStore;
  24. }

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

  1. @Override
  2. protected boolean shouldSplit() {
  3.  boolean force = region.shouldForceSplit();
  4.  boolean foundABigStore = false;
  5.  for (HStore store : region.getStores()) {
  6.   // If any of the stores are unable to split (eg they contain reference files)
  7.   // then don't split
  8.   if ((!store.canSplit())) {
  9.    return false;
  10.   }
  11.   // Mark if any store is big enough
  12.   if (store.getSize() > desiredMaxFileSize) {
  13.    foundABigStore = true;
  14.   }
  15.  }
  16.  return foundABigStore || force;
  17. }

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

  1. @Test
  2. public void testGetSplitPoint() throws IOException {
  3.  ConstantSizeRegionSplitPolicy policy =
  4.   (ConstantSizeRegionSplitPolicy)RegionSplitPolicy.create(mockRegion, conf);
  5.  // For no stores, should not split
  6.  assertFalse(policy.shouldSplit());
  7.  assertNull(policy.getSplitPoint());
  8.  // Add a store above the requisite size. Should split.
  9.  HStore mockStore = Mockito.mock(HStore.class);
  10.  Mockito.doReturn(2000L).when(mockStore).getSize();
  11.  Mockito.doReturn(true).when(mockStore).canSplit();
  12.  Mockito.doReturn(Optional.of(Bytes.toBytes("store 1 split"))).when(mockStore).getSplitPoint();
  13.  stores.add(mockStore);
  14.  assertEquals("store 1 split",
  15.    Bytes.toString(policy.getSplitPoint()));
  16.  // Add a bigger store. The split point should come from that one
  17.  HStore mockStore2 = Mockito.mock(HStore.class);
  18.  Mockito.doReturn(4000L).when(mockStore2).getSize();
  19.  Mockito.doReturn(true).when(mockStore2).canSplit();
  20.  Mockito.doReturn(Optional.of(Bytes.toBytes("store 2 split"))).when(mockStore2).getSplitPoint();
  21.  stores.add(mockStore2);
  22.  assertEquals("store 2 split",
  23.    Bytes.toString(policy.getSplitPoint()));
  24. }

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

  1. @Test
  2. public void testConstantSizePolicyWithJitter() throws IOException {
  3.  conf.set(HConstants.HBASE_REGION_SPLIT_POLICY_KEY,
  4.   ConstantSizeRegionSplitPolicy.class.getName());
  5.  htd.setMaxFileSize(Long.MAX_VALUE);
  6.  boolean positiveJitter = false;
  7.  ConstantSizeRegionSplitPolicy policy = null;
  8.  while (!positiveJitter) {
  9.   policy = (ConstantSizeRegionSplitPolicy) RegionSplitPolicy.create(mockRegion, conf);
  10.   positiveJitter = policy.positiveJitterRate();
  11.  }
  12.  // add a store
  13.  HStore mockStore = Mockito.mock(HStore.class);
  14.  Mockito.doReturn(2000L).when(mockStore).getSize();
  15.  Mockito.doReturn(true).when(mockStore).canSplit();
  16.  stores.add(mockStore);
  17.  // Jitter shouldn't cause overflow when HTableDescriptor.MAX_FILESIZE set to Long.MAX_VALUE
  18.  assertFalse(policy.shouldSplit());
  19. }

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

  1. /**
  2.  * Test setting up a customized split policy
  3.  */
  4. @Test
  5. public void testCustomPolicy() throws IOException {
  6.  HTableDescriptor myHtd = new HTableDescriptor(TableName.valueOf(name.getMethodName()));
  7.  myHtd.setValue(HTableDescriptor.SPLIT_POLICY,
  8.    KeyPrefixRegionSplitPolicy.class.getName());
  9.  myHtd.setValue(KeyPrefixRegionSplitPolicy.PREFIX_LENGTH_KEY, String.valueOf(2));
  10.  HRegion myMockRegion = Mockito.mock(HRegion.class);
  11.  Mockito.doReturn(myHtd).when(myMockRegion).getTableDescriptor();
  12.  Mockito.doReturn(stores).when(myMockRegion).getStores();
  13.  HStore mockStore = Mockito.mock(HStore.class);
  14.  Mockito.doReturn(2000L).when(mockStore).getSize();
  15.  Mockito.doReturn(true).when(mockStore).canSplit();
  16.  Mockito.doReturn(Optional.of(Bytes.toBytes("abcd"))).when(mockStore).getSplitPoint();
  17.  stores.add(mockStore);
  18.  KeyPrefixRegionSplitPolicy policy = (KeyPrefixRegionSplitPolicy) RegionSplitPolicy
  19.    .create(myMockRegion, conf);
  20.  assertEquals("ab", Bytes.toString(policy.getSplitPoint()));
  21.  Mockito.doReturn(true).when(myMockRegion).shouldForceSplit();
  22.  Mockito.doReturn(Bytes.toBytes("efgh")).when(myMockRegion)
  23.    .getExplicitSplitPoint();
  24.  policy = (KeyPrefixRegionSplitPolicy) RegionSplitPolicy
  25.    .create(myMockRegion, conf);
  26.  assertEquals("ef", Bytes.toString(policy.getSplitPoint()));
  27. }

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

  1. @Test
  2. public void testDelimitedKeyPrefixRegionSplitPolicy() throws IOException {
  3.  HTableDescriptor myHtd = new HTableDescriptor(TableName.valueOf(name.getMethodName()));
  4.  myHtd.setValue(HTableDescriptor.SPLIT_POLICY,
  5.    DelimitedKeyPrefixRegionSplitPolicy.class.getName());
  6.  myHtd.setValue(DelimitedKeyPrefixRegionSplitPolicy.DELIMITER_KEY, ",");
  7.  HRegion myMockRegion = Mockito.mock(HRegion.class);
  8.  Mockito.doReturn(myHtd).when(myMockRegion).getTableDescriptor();
  9.  Mockito.doReturn(stores).when(myMockRegion).getStores();
  10.  HStore mockStore = Mockito.mock(HStore.class);
  11.  Mockito.doReturn(2000L).when(mockStore).getSize();
  12.  Mockito.doReturn(true).when(mockStore).canSplit();
  13.  Mockito.doReturn(Optional.of(Bytes.toBytes("ab,cd"))).when(mockStore).getSplitPoint();
  14.  stores.add(mockStore);
  15.  DelimitedKeyPrefixRegionSplitPolicy policy = (DelimitedKeyPrefixRegionSplitPolicy) RegionSplitPolicy
  16.    .create(myMockRegion, conf);
  17.  assertEquals("ab", Bytes.toString(policy.getSplitPoint()));
  18.  Mockito.doReturn(true).when(myMockRegion).shouldForceSplit();
  19.  Mockito.doReturn(Bytes.toBytes("efg,h")).when(myMockRegion)
  20.    .getExplicitSplitPoint();
  21.  policy = (DelimitedKeyPrefixRegionSplitPolicy) RegionSplitPolicy
  22.    .create(myMockRegion, conf);
  23.  assertEquals("efg", Bytes.toString(policy.getSplitPoint()));
  24.  Mockito.doReturn(Bytes.toBytes("ijk")).when(myMockRegion)
  25.  .getExplicitSplitPoint();
  26.  assertEquals("ijk", Bytes.toString(policy.getSplitPoint()));
  27. }

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

  1. @Override
  2. protected boolean shouldSplit() {
  3.  boolean force = region.shouldForceSplit();
  4.  boolean foundABigStore = false;
  5.  // Get count of regions that have the same common table as this.region
  6.  int tableRegionsCount = getCountOfCommonTableRegions();
  7.  // Get size to check
  8.  long sizeToCheck = getSizeToCheck(tableRegionsCount);
  9.  for (HStore store : region.getStores()) {
  10.   // If any of the stores is unable to split (eg they contain reference files)
  11.   // then don't split
  12.   if (!store.canSplit()) {
  13.    return false;
  14.   }
  15.   // Mark if any store is big enough
  16.   long size = store.getSize();
  17.   if (size > sizeToCheck) {
  18.    LOG.debug("ShouldSplit because " + store.getColumnFamilyName() +
  19.     " size=" + StringUtils.humanSize(size) +
  20.     ", sizeToCheck=" + StringUtils.humanSize(sizeToCheck) +
  21.     ", regionsWithCommonTable=" + tableRegionsCount);
  22.    foundABigStore = true;
  23.   }
  24.  }
  25.  return foundABigStore || force;
  26. }

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

  1. /**
  2.  * Run through tests for a ConstantSizeRegionSplitPolicy
  3.  * @param policy
  4.  */
  5. private void doConstantSizePolicyTests(final ConstantSizeRegionSplitPolicy policy) {
  6.  // For no stores, should not split
  7.  assertFalse(policy.shouldSplit());
  8.  // Add a store above the requisite size. Should split.
  9.  HStore mockStore = Mockito.mock(HStore.class);
  10.  Mockito.doReturn(2000L).when(mockStore).getSize();
  11.  Mockito.doReturn(true).when(mockStore).canSplit();
  12.  stores.add(mockStore);
  13.  assertTrue(policy.shouldSplit());
  14.  // Act as if there's a reference file or some other reason it can't split.
  15.  // This should prevent splitting even though it's big enough.
  16.  Mockito.doReturn(false).when(mockStore).canSplit();
  17.  assertFalse(policy.shouldSplit());
  18.  // Reset splittability after above
  19.  Mockito.doReturn(true).when(mockStore).canSplit();
  20.  // Set to a small size but turn on forceSplit. Should result in a split.
  21.  Mockito.doReturn(true).when(mockRegion).shouldForceSplit();
  22.  Mockito.doReturn(100L).when(mockStore).getSize();
  23.  assertTrue(policy.shouldSplit());
  24.  // Turn off forceSplit, should not split
  25.  Mockito.doReturn(false).when(mockRegion).shouldForceSplit();
  26.  assertFalse(policy.shouldSplit());
  27.  // Clear families we added above
  28.  stores.clear();
  29. }

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

  1. @Test
  2. public void testForceSplitRegionWithReference() throws IOException {
  3.  htd.setMaxFileSize(1024L);
  4.  // Add a store above the requisite size. Should split.
  5.  HStore mockStore = Mockito.mock(HStore.class);
  6.  Mockito.doReturn(2000L).when(mockStore).getSize();
  7.  // Act as if there's a reference file or some other reason it can't split.
  8.  // This should prevent splitting even though it's big enough.
  9.  Mockito.doReturn(false).when(mockStore).canSplit();
  10.  stores.add(mockStore);
  11.  conf.set(HConstants.HBASE_REGION_SPLIT_POLICY_KEY,
  12.   ConstantSizeRegionSplitPolicy.class.getName());
  13.  ConstantSizeRegionSplitPolicy policy =
  14.    (ConstantSizeRegionSplitPolicy)RegionSplitPolicy.create(mockRegion, conf);
  15.  assertFalse(policy.shouldSplit());
  16.  Mockito.doReturn(true).when(mockRegion).shouldForceSplit();
  17.  assertFalse(policy.shouldSplit());
  18.  Mockito.doReturn(false).when(mockRegion).shouldForceSplit();
  19.  conf.set(HConstants.HBASE_REGION_SPLIT_POLICY_KEY,
  20.   IncreasingToUpperBoundRegionSplitPolicy.class.getName());
  21.  policy = (IncreasingToUpperBoundRegionSplitPolicy) RegionSplitPolicy.create(mockRegion, conf);
  22.  assertFalse(policy.shouldSplit());
  23.  Mockito.doReturn(true).when(mockRegion).shouldForceSplit();
  24.  assertFalse(policy.shouldSplit());
  25. }

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

  1. Mockito.doReturn(2000L).when(mockStore).getSize();
  2. Mockito.doReturn(true).when(mockStore).canSplit();
  3. stores.add(mockStore);
  4. Mockito.doReturn(flushSize).when(mockStore).getSize();
  5. Mockito.doReturn(flushSize*2 + 1).when(mockStore).getSize();
  6. assertTrue(policy.shouldSplit());
  7. assertFalse(policy.shouldSplit());
  8. Mockito.doReturn((long)(maxSplitSize * 1.25 + 1)).when(mockStore).getSize();
  9. assertTrue(policy.shouldSplit());

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

  1. long expectedStoreFilesSize = store.getStorefilesSize();
  2. Assert.assertNotNull(store);
  3. Assert.assertEquals(expectedStoreFilesSize, store.getSize());
  4.  Assert.assertEquals(expectedStoreFilesSize, store.getSize());

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

  1. long regionMemstoreSize = secondaryRegion.getMemStoreDataSize();
  2. MemStoreSize mss = store.getFlushableSize();
  3. long storeSize = store.getSize();
  4. long storeSizeUncompressed = store.getStoreSizeUncompressed();
  5. if (flushDesc.getAction() == FlushAction.START_FLUSH) {
  6.  assertTrue(store.getSize() > storeSize);
  7.  assertTrue(store.getStoreSizeUncompressed() > storeSizeUncompressed);
  8.  assertEquals(store.getSize(), store.getStorefilesSize());

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

  1. .startsWith(QueryConstants.LOCAL_INDEX_COLUMN_FAMILY_PREFIX)) {
  2. Optional<byte[]> splitPoint = s.getSplitPoint();
  3. long storeSize = s.getSize();
  4. if (splitPoint.isPresent() && largestStoreSize < storeSize) {
  5.   splitPointFromLargestStore = splitPoint.get();

代码示例来源：origin: com.aliyun.phoenix/ali-phoenix-core

  1. .startsWith(QueryConstants.LOCAL_INDEX_COLUMN_FAMILY_PREFIX)) {
  2. Optional<byte[]> splitPoint = s.getSplitPoint();
  3. long storeSize = s.getSize();
  4. if (splitPoint.isPresent() && largestStoreSize < storeSize) {
  5.   splitPointFromLargestStore = splitPoint.get();

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

  1. @Test
  2. public void testGetSplitPoint() throws IOException {
  3.  ConstantSizeRegionSplitPolicy policy =
  4.   (ConstantSizeRegionSplitPolicy)RegionSplitPolicy.create(mockRegion, conf);
  5.  // For no stores, should not split
  6.  assertFalse(policy.shouldSplit());
  7.  assertNull(policy.getSplitPoint());
  8.  // Add a store above the requisite size. Should split.
  9.  HStore mockStore = Mockito.mock(HStore.class);
  10.  Mockito.doReturn(2000L).when(mockStore).getSize();
  11.  Mockito.doReturn(true).when(mockStore).canSplit();
  12.  Mockito.doReturn(Optional.of(Bytes.toBytes("store 1 split"))).when(mockStore).getSplitPoint();
  13.  stores.add(mockStore);
  14.  assertEquals("store 1 split",
  15.    Bytes.toString(policy.getSplitPoint()));
  16.  // Add a bigger store. The split point should come from that one
  17.  HStore mockStore2 = Mockito.mock(HStore.class);
  18.  Mockito.doReturn(4000L).when(mockStore2).getSize();
  19.  Mockito.doReturn(true).when(mockStore2).canSplit();
  20.  Mockito.doReturn(Optional.of(Bytes.toBytes("store 2 split"))).when(mockStore2).getSplitPoint();
  21.  stores.add(mockStore2);
  22.  assertEquals("store 2 split",
  23.    Bytes.toString(policy.getSplitPoint()));
  24. }

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

  1. @Test
  2. public void testConstantSizePolicyWithJitter() throws IOException {
  3.  conf.set(HConstants.HBASE_REGION_SPLIT_POLICY_KEY,
  4.   ConstantSizeRegionSplitPolicy.class.getName());
  5.  htd.setMaxFileSize(Long.MAX_VALUE);
  6.  boolean positiveJitter = false;
  7.  ConstantSizeRegionSplitPolicy policy = null;
  8.  while (!positiveJitter) {
  9.   policy = (ConstantSizeRegionSplitPolicy) RegionSplitPolicy.create(mockRegion, conf);
  10.   positiveJitter = policy.positiveJitterRate();
  11.  }
  12.  // add a store
  13.  HStore mockStore = Mockito.mock(HStore.class);
  14.  Mockito.doReturn(2000L).when(mockStore).getSize();
  15.  Mockito.doReturn(true).when(mockStore).canSplit();
  16.  stores.add(mockStore);
  17.  // Jitter shouldn't cause overflow when HTableDescriptor.MAX_FILESIZE set to Long.MAX_VALUE
  18.  assertFalse(policy.shouldSplit());
  19. }

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

  1. /**
  2.  * Test setting up a customized split policy
  3.  */
  4. @Test
  5. public void testCustomPolicy() throws IOException {
  6.  HTableDescriptor myHtd = new HTableDescriptor(TableName.valueOf(name.getMethodName()));
  7.  myHtd.setValue(HTableDescriptor.SPLIT_POLICY,
  8.    KeyPrefixRegionSplitPolicy.class.getName());
  9.  myHtd.setValue(KeyPrefixRegionSplitPolicy.PREFIX_LENGTH_KEY, String.valueOf(2));
  10.  HRegion myMockRegion = Mockito.mock(HRegion.class);
  11.  Mockito.doReturn(myHtd).when(myMockRegion).getTableDescriptor();
  12.  Mockito.doReturn(stores).when(myMockRegion).getStores();
  13.  HStore mockStore = Mockito.mock(HStore.class);
  14.  Mockito.doReturn(2000L).when(mockStore).getSize();
  15.  Mockito.doReturn(true).when(mockStore).canSplit();
  16.  Mockito.doReturn(Optional.of(Bytes.toBytes("abcd"))).when(mockStore).getSplitPoint();
  17.  stores.add(mockStore);
  18.  KeyPrefixRegionSplitPolicy policy = (KeyPrefixRegionSplitPolicy) RegionSplitPolicy
  19.    .create(myMockRegion, conf);
  20.  assertEquals("ab", Bytes.toString(policy.getSplitPoint()));
  21.  Mockito.doReturn(true).when(myMockRegion).shouldForceSplit();
  22.  Mockito.doReturn(Bytes.toBytes("efgh")).when(myMockRegion)
  23.    .getExplicitSplitPoint();
  24.  policy = (KeyPrefixRegionSplitPolicy) RegionSplitPolicy
  25.    .create(myMockRegion, conf);
  26.  assertEquals("ef", Bytes.toString(policy.getSplitPoint()));
  27. }

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

  1. @Test
  2. public void testDelimitedKeyPrefixRegionSplitPolicy() throws IOException {
  3.  HTableDescriptor myHtd = new HTableDescriptor(TableName.valueOf(name.getMethodName()));
  4.  myHtd.setValue(HTableDescriptor.SPLIT_POLICY,
  5.    DelimitedKeyPrefixRegionSplitPolicy.class.getName());
  6.  myHtd.setValue(DelimitedKeyPrefixRegionSplitPolicy.DELIMITER_KEY, ",");
  7.  HRegion myMockRegion = Mockito.mock(HRegion.class);
  8.  Mockito.doReturn(myHtd).when(myMockRegion).getTableDescriptor();
  9.  Mockito.doReturn(stores).when(myMockRegion).getStores();
  10.  HStore mockStore = Mockito.mock(HStore.class);
  11.  Mockito.doReturn(2000L).when(mockStore).getSize();
  12.  Mockito.doReturn(true).when(mockStore).canSplit();
  13.  Mockito.doReturn(Optional.of(Bytes.toBytes("ab,cd"))).when(mockStore).getSplitPoint();
  14.  stores.add(mockStore);
  15.  DelimitedKeyPrefixRegionSplitPolicy policy = (DelimitedKeyPrefixRegionSplitPolicy) RegionSplitPolicy
  16.    .create(myMockRegion, conf);
  17.  assertEquals("ab", Bytes.toString(policy.getSplitPoint()));
  18.  Mockito.doReturn(true).when(myMockRegion).shouldForceSplit();
  19.  Mockito.doReturn(Bytes.toBytes("efg,h")).when(myMockRegion)
  20.    .getExplicitSplitPoint();
  21.  policy = (DelimitedKeyPrefixRegionSplitPolicy) RegionSplitPolicy
  22.    .create(myMockRegion, conf);
  23.  assertEquals("efg", Bytes.toString(policy.getSplitPoint()));
  24.  Mockito.doReturn(Bytes.toBytes("ijk")).when(myMockRegion)
  25.  .getExplicitSplitPoint();
  26.  assertEquals("ijk", Bytes.toString(policy.getSplitPoint()));
  27. }

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

  1. /**
  2.  * Run through tests for a ConstantSizeRegionSplitPolicy
  3.  * @param policy
  4.  */
  5. private void doConstantSizePolicyTests(final ConstantSizeRegionSplitPolicy policy) {
  6.  // For no stores, should not split
  7.  assertFalse(policy.shouldSplit());
  8.  // Add a store above the requisite size. Should split.
  9.  HStore mockStore = Mockito.mock(HStore.class);
  10.  Mockito.doReturn(2000L).when(mockStore).getSize();
  11.  Mockito.doReturn(true).when(mockStore).canSplit();
  12.  stores.add(mockStore);
  13.  assertTrue(policy.shouldSplit());
  14.  // Act as if there's a reference file or some other reason it can't split.
  15.  // This should prevent splitting even though it's big enough.
  16.  Mockito.doReturn(false).when(mockStore).canSplit();
  17.  assertFalse(policy.shouldSplit());
  18.  // Reset splittability after above
  19.  Mockito.doReturn(true).when(mockStore).canSplit();
  20.  // Set to a small size but turn on forceSplit. Should result in a split.
  21.  Mockito.doReturn(true).when(mockRegion).shouldForceSplit();
  22.  Mockito.doReturn(100L).when(mockStore).getSize();
  23.  assertTrue(policy.shouldSplit());
  24.  // Turn off forceSplit, should not split
  25.  Mockito.doReturn(false).when(mockRegion).shouldForceSplit();
  26.  assertFalse(policy.shouldSplit());
  27.  // Clear families we added above
  28.  stores.clear();
  29. }

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

  1. @Test
  2. public void testForceSplitRegionWithReference() throws IOException {
  3.  htd.setMaxFileSize(1024L);
  4.  // Add a store above the requisite size. Should split.
  5.  HStore mockStore = Mockito.mock(HStore.class);
  6.  Mockito.doReturn(2000L).when(mockStore).getSize();
  7.  // Act as if there's a reference file or some other reason it can't split.
  8.  // This should prevent splitting even though it's big enough.
  9.  Mockito.doReturn(false).when(mockStore).canSplit();
  10.  stores.add(mockStore);
  11.  conf.set(HConstants.HBASE_REGION_SPLIT_POLICY_KEY,
  12.   ConstantSizeRegionSplitPolicy.class.getName());
  13.  ConstantSizeRegionSplitPolicy policy =
  14.    (ConstantSizeRegionSplitPolicy)RegionSplitPolicy.create(mockRegion, conf);
  15.  assertFalse(policy.shouldSplit());
  16.  Mockito.doReturn(true).when(mockRegion).shouldForceSplit();
  17.  assertFalse(policy.shouldSplit());
  18.  Mockito.doReturn(false).when(mockRegion).shouldForceSplit();
  19.  conf.set(HConstants.HBASE_REGION_SPLIT_POLICY_KEY,
  20.   IncreasingToUpperBoundRegionSplitPolicy.class.getName());
  21.  policy = (IncreasingToUpperBoundRegionSplitPolicy) RegionSplitPolicy.create(mockRegion, conf);
  22.  assertFalse(policy.shouldSplit());
  23.  Mockito.doReturn(true).when(mockRegion).shouldForceSplit();
  24.  assertFalse(policy.shouldSplit());
  25. }

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

HStore

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    HStore类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com