diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestBigLinkedList.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestBigLinkedList.java index 841d7d0..e8c881d 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestBigLinkedList.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestBigLinkedList.java @@ -59,6 +59,7 @@ import org.apache.hadoop.hbase.HTableDescriptor; import org.apache.hadoop.hbase.IntegrationTestBase; import org.apache.hadoop.hbase.IntegrationTestingUtility; import org.apache.hadoop.hbase.MasterNotRunningException; +import org.apache.hadoop.hbase.MemoryCompactionPolicy; import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.client.Admin; import org.apache.hadoop.hbase.client.BufferedMutator; @@ -702,7 +703,13 @@ public class IntegrationTestBigLinkedList extends IntegrationTestBase { hcd.setMobThreshold(4); } } - + // if -DinMemoryCompaction=, set policy accordingly + String inMemCompaction = conf.get("inMemoryCompaction", null); + if (inMemCompaction != null) { + for (HColumnDescriptor hcd : htd.getColumnFamilies()) { + hcd.setInMemoryCompaction(MemoryCompactionPolicy.valueOf(inMemCompaction)); + } + } // If we want to pre-split compute how many splits. if (conf.getBoolean(HBaseTestingUtility.PRESPLIT_TEST_TABLE_KEY, HBaseTestingUtility.PRESPLIT_TEST_TABLE)) { @@ -1844,6 +1851,8 @@ public class IntegrationTestBigLinkedList extends IntegrationTestBase { System.err.println(" Create table so that the mob read/write path is forced. " + "Defaults to false"); + System.err.println(" -DinMemoryCompaction="); + System.err.println(" Specify in memory compaction policy. Default is None"); System.err.flush(); }