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..52b8a1a 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; @@ -201,6 +202,8 @@ public class IntegrationTestBigLinkedList extends IntegrationTestBase { private static byte[] BIG_FAMILY_NAME = Bytes.toBytes("big"); private static byte[] TINY_FAMILY_NAME = Bytes.toBytes("tiny"); + private static String IN_MEM_COMPACTION = "inMemoryCompaction"; + //link to the id of the prev node in the linked list protected static final byte[] COLUMN_PREV = Bytes.toBytes("prev"); @@ -702,7 +705,13 @@ public class IntegrationTestBigLinkedList extends IntegrationTestBase { hcd.setMobThreshold(4); } } - + // if -DinMemoryCompaction=, set policy accordingly + String inMemCompaction = conf.get(IN_MEM_COMPACTION, 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 +1853,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(); }