1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 package org.apache.hadoop.hbase;
20
21 import java.io.IOException;
22
23 import org.apache.hadoop.conf.Configuration;
24 import org.apache.hadoop.hbase.regionserver.HStore;
25 import org.apache.hadoop.hbase.regionserver.StoreEngine;
26 import org.apache.hadoop.hbase.regionserver.StripeStoreEngine;
27 import org.apache.hadoop.hbase.testclassification.IntegrationTests;
28 import org.apache.hadoop.hbase.util.LoadTestTool;
29 import org.apache.hadoop.util.ToolRunner;
30 import org.junit.experimental.categories.Category;
31
32
33
34
35
36 @Category(IntegrationTests.class)
37 public class IntegrationTestIngestStripeCompactions extends IntegrationTestIngest {
38 @Override
39 protected void initTable() throws IOException {
40
41 HTableDescriptor htd = new HTableDescriptor(getTablename());
42 htd.setConfiguration(StoreEngine.STORE_ENGINE_CLASS_KEY, StripeStoreEngine.class.getName());
43 htd.setConfiguration(HStore.BLOCKING_STOREFILES_KEY, "100");
44 HColumnDescriptor hcd = new HColumnDescriptor(LoadTestTool.DEFAULT_COLUMN_FAMILY);
45 HBaseTestingUtility.createPreSplitLoadTestTable(util.getConfiguration(), htd, hcd);
46 }
47
48 public static void main(String[] args) throws Exception {
49 Configuration conf = HBaseConfiguration.create();
50 IntegrationTestingUtility.setUseDistributedCluster(conf);
51 int ret = ToolRunner.run(conf, new IntegrationTestIngestStripeCompactions(), args);
52 System.exit(ret);
53 }
54 }