1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18 package org.apache.hadoop.hbase.client;
19
20 import org.apache.hadoop.conf.Configuration;
21 import org.apache.hadoop.hbase.CategoryBasedTimeout;
22 import org.apache.hadoop.hbase.coprocessor.CoprocessorHost;
23 import org.apache.hadoop.hbase.coprocessor.MultiRowMutationEndpoint;
24 import org.apache.hadoop.hbase.regionserver.NoOpScanPolicyObserver;
25 import org.apache.hadoop.hbase.testclassification.LargeTests;
26 import org.junit.Before;
27 import org.junit.Rule;
28 import org.junit.experimental.categories.Category;
29 import org.junit.rules.TestRule;
30
31
32
33
34
35
36
37
38 @Category(LargeTests.class)
39 public class TestIncrementFromClientSideWithCoprocessor extends TestIncrementsFromClientSide {
40 @Rule public final TestRule timeout = CategoryBasedTimeout.builder().withTimeout(this.getClass()).
41 withLookingForStuckThread(true).build();
42 @Before
43 public void before() throws Exception {
44 Configuration conf = TEST_UTIL.getConfiguration();
45 conf.setStrings(CoprocessorHost.REGION_COPROCESSOR_CONF_KEY,
46 MultiRowMutationEndpoint.class.getName(), NoOpScanPolicyObserver.class.getName());
47 conf.setBoolean("hbase.table.sanity.checks", true);
48 }
49 }