1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 package org.apache.hadoop.hbase.chaos.actions;
20
21 import java.util.Random;
22
23 import org.apache.hadoop.hbase.HBaseTestingUtility;
24 import org.apache.hadoop.hbase.HColumnDescriptor;
25 import org.apache.hadoop.hbase.HTableDescriptor;
26 import org.apache.hadoop.hbase.client.HBaseAdmin;
27 import org.apache.hadoop.hbase.regionserver.BloomType;
28 import org.apache.hadoop.hbase.util.Bytes;
29
30
31
32
33
34 public class ChangeBloomFilterAction extends Action {
35 private final byte[] tableNameBytes;
36 private final long sleepTime;
37 private final String tableName;
38
39 public ChangeBloomFilterAction(String tableName) {
40 this(-1, tableName);
41 }
42
43 public ChangeBloomFilterAction(int sleepTime, String tableName) {
44 this.tableNameBytes = Bytes.toBytes(tableName);
45 this.sleepTime = sleepTime;
46 this.tableName = tableName;
47 }
48
49 @Override
50 public void perform() throws Exception {
51 Random random = new Random();
52 HBaseTestingUtility util = context.getHBaseIntegrationTestingUtility();
53 HBaseAdmin admin = util.getHBaseAdmin();
54
55 LOG.info("Performing action: Change bloom filter on all columns of table "
56 + tableName);
57 HTableDescriptor tableDescriptor = admin.getTableDescriptor(Bytes
58 .toBytes(tableName));
59 HColumnDescriptor[] columnDescriptors = tableDescriptor.getColumnFamilies();
60
61 if (columnDescriptors == null || columnDescriptors.length == 0) {
62 return;
63 }
64
65 final BloomType[] bloomArray = BloomType.values();
66 final int bloomArraySize = bloomArray.length;
67
68 for (HColumnDescriptor descriptor : columnDescriptors) {
69 int bloomFilterIndex = random.nextInt(bloomArraySize);
70 LOG.debug("Performing action: About to set bloom filter type to "
71 + bloomArray[bloomFilterIndex] + " on column "
72 + descriptor.getNameAsString() + " of table " + tableName);
73 descriptor.setBloomFilterType(bloomArray[bloomFilterIndex]);
74 LOG.debug("Performing action: Just set bloom filter type to "
75 + bloomArray[bloomFilterIndex] + " on column "
76 + descriptor.getNameAsString() + " of table " + tableName);
77 }
78
79 admin.modifyTable(tableName, tableDescriptor);
80 }
81 }