File tree Expand file tree Collapse file tree 2 files changed +0
-16
lines changed
src/main/java/com/alipay/oceanbase/hbase Expand file tree Collapse file tree 2 files changed +0
-16
lines changed Original file line number Diff line number Diff line change 23
23
import com .alipay .oceanbase .hbase .filter .HBaseFilterUtils ;
24
24
import com .alipay .oceanbase .hbase .result .ClientStreamScanner ;
25
25
import com .alipay .oceanbase .hbase .util .*;
26
- import com .alipay .oceanbase .rpc .ObGlobal ;
27
26
import com .alipay .oceanbase .rpc .ObTableClient ;
28
27
import com .alipay .oceanbase .rpc .exception .ObTableException ;
29
28
import com .alipay .oceanbase .rpc .location .model .partition .Partition ;
Original file line number Diff line number Diff line change 21
21
import com .alipay .oceanbase .rpc .constant .Constants ;
22
22
import com .google .common .base .Objects ;
23
23
import org .apache .hadoop .classification .InterfaceAudience ;
24
- import org .apache .hadoop .conf .Configuration ;
25
- import org .apache .hadoop .hbase .client .ConnectionConfiguration ;
26
24
27
25
import java .io .IOException ;
28
26
import java .util .Map ;
29
27
import java .util .Properties ;
30
28
import java .util .concurrent .ConcurrentHashMap ;
31
- import java .util .concurrent .ExecutionException ;
32
29
import java .util .concurrent .locks .ReentrantLock ;
33
30
34
31
import static com .alipay .oceanbase .hbase .constants .OHConstants .*;
@@ -129,18 +126,6 @@ public static ObTableClient getOrCreateObTableClient(ObTableClientKey obTableCli
129
126
return OB_TABLE_CLIENT_INSTANCE .get (obTableClientKey );
130
127
}
131
128
132
- public static void clear () throws IOException {
133
- try {
134
- for (Map .Entry <ObTableClientKey , ObTableClient > pair : OB_TABLE_CLIENT_INSTANCE .entrySet ()) {
135
- pair .getValue ().close ();
136
- }
137
- }
138
- catch (Exception e ) {
139
- throw new IOException ("fail to close tableClient" , e );
140
- }
141
- OB_TABLE_CLIENT_INSTANCE .clear ();
142
- }
143
-
144
129
public static class ObTableClientKey {
145
130
private String paramUrl ;
146
131
private String fullUserName ;
You can’t perform that action at this time.
0 commit comments