1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18 package org.apache.hadoop.hbase.regionserver.compactions;
19
20 import org.apache.hadoop.hbase.HBaseInterfaceAudience;
21 import org.apache.hadoop.hbase.classification.InterfaceAudience;
22 import org.apache.hadoop.hbase.regionserver.RegionServerServices;
23
24
25
26
27 @InterfaceAudience.LimitedPrivate(HBaseInterfaceAudience.CONFIG)
28 public class NoLimitCompactionThroughputController implements CompactionThroughputController {
29
30 public static final NoLimitCompactionThroughputController INSTANCE =
31 new NoLimitCompactionThroughputController();
32
33 @Override
34 public void setup(RegionServerServices server) {
35 }
36
37 @Override
38 public void start(String compactionName) {
39 }
40
41 @Override
42 public long control(String compactionName, long size) throws InterruptedException {
43 return 0;
44 }
45
46 @Override
47 public void finish(String compactionName) {
48 }
49
50 private volatile boolean stopped;
51
52 @Override
53 public void stop(String why) {
54 stopped = true;
55 }
56
57 @Override
58 public boolean isStopped() {
59 return stopped;
60 }
61
62 @Override
63 public String toString() {
64 return "NoLimitCompactionThroughputController";
65 }
66 }