Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
41 commits
Select commit Hold shift + click to select a range
03c8e71
add DepentdentFilter and SingleColumnValueExcludeFilter
JackShi148 Oct 11, 2024
2aaf7c4
add singleColumnValueExcludeFilter and DependentColumnFilter; add tes…
JackShi148 Oct 16, 2024
fe21f09
merge into branch-1.3
JackShi148 Oct 17, 2024
3830246
Merge remote-tracking branch 'obkv/branch-1.3' into JackShi148/branch…
JackShi148 Oct 22, 2024
be654df
hbase support batch (#84)
stuBirdFly Oct 22, 2024
a82b46d
Merge remote-tracking branch 'obkv/branch-1.3' into branch-1.3
JackShi148 Oct 23, 2024
697c5d0
Add DeleteFamilyVersion function and corresponding test cases (#85)
JackShi148 Oct 23, 2024
144a77b
Merge remote-tracking branch 'obkv/branch-1.3' into branch-1.3
JackShi148 Oct 23, 2024
7733e4a
remove DeleteFamilyVersion file and move all cases to MultiColumnFami…
JackShi148 Oct 23, 2024
3411491
hbase support batchCallBack (#86)
stuBirdFly Oct 23, 2024
9c6be3f
adjust bufferdMutatorImpl 1.x to new batch
JackShi148 Oct 23, 2024
5347033
bufferedMutator do not retry, batch retry in table client
JackShi148 Oct 23, 2024
df4f7a8
Merge branch 'branch-1.3' into buffermutator_batch
JackShi148 Oct 23, 2024
d1d5b52
hbase support batch (#84)
stuBirdFly Oct 22, 2024
6081400
add rpcTimeout and operationTimetout setting in bufferedMutator
JackShi148 Oct 24, 2024
b830a72
Merge remote-tracking branch 'myfork/buffermutator_batch' into buffer…
JackShi148 Oct 24, 2024
4968a46
initial merge into hbase_2.0
JackShi148 Oct 24, 2024
3884e08
fix test
miyuan-ljr Oct 24, 2024
676ec51
Add DeleteFamilyVersion function and corresponding test cases (#85)
JackShi148 Oct 23, 2024
5d43b53
hbase support batchCallBack (#86)
stuBirdFly Oct 23, 2024
f801cfe
fix test
miyuan-ljr Oct 24, 2024
4c96d00
fix test
miyuan-ljr Oct 25, 2024
f8568b6
init hbase_2.0 bufferedMutatorImpl
JackShi148 Oct 25, 2024
56f838f
pass single bufferedMutator test
JackShi148 Oct 25, 2024
24ae6d7
remove useless comments
JackShi148 Oct 25, 2024
17f045d
pass mulfi-cf bufferedMutator tests
JackShi148 Oct 25, 2024
20a689a
format code
JackShi148 Oct 25, 2024
6759d96
add inherited interface in bufferedMutator; fix concurrent bug in buf…
JackShi148 Oct 25, 2024
25cdbca
merge into hbase_2.0
JackShi148 Oct 28, 2024
3a44d73
fix typo
JackShi148 Oct 28, 2024
21c6a0f
fix exception erros message
JackShi148 Oct 28, 2024
14fc146
update time to wait pool to shutdown
JackShi148 Oct 28, 2024
3ffb260
merge into hbase_2.0
JackShi148 Oct 29, 2024
e51e6be
add import
JackShi148 Oct 29, 2024
9cde5ba
pass test cases after merge
JackShi148 Oct 29, 2024
baf4dd5
Merge remote-tracking branch 'obkv/hbase_2.0' into hbase_2.0
JackShi148 Oct 30, 2024
d578e7c
Merge remote-tracking branch 'obkv/hbase_2.0' into hbase_2.0
JackShi148 Oct 30, 2024
77d1e76
keep the same test case and sql with 1.x version
JackShi148 Oct 30, 2024
ad05f11
Merge branch 'hbase_2.0' of github.com:oceanbase/obkv-hbase-client-ja…
JackShi148 Dec 4, 2024
b12d873
fix connection re-used between files because of incorrect close
JackShi148 Dec 4, 2024
d8fa2b8
close all obTableClient when closing OHTable and clear cache
JackShi148 Dec 5, 2024
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions src/main/java/com/alipay/oceanbase/hbase/OHTable.java
Original file line number Diff line number Diff line change
Expand Up @@ -1464,6 +1464,7 @@ public void close() throws IOException {
if (cleanupPoolOnClose) {
executePool.shutdown();
}
ObTableClientManager.clear();
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -126,6 +126,18 @@ public static ObTableClient getOrCreateObTableClient(ObTableClientKey obTableCli
return OB_TABLE_CLIENT_INSTANCE.get(obTableClientKey);
}

public static void clear() throws IOException {
try {
for (Map.Entry<ObTableClientKey, ObTableClient> pair : OB_TABLE_CLIENT_INSTANCE.entrySet()) {
pair.getValue().close();
}
}
catch (Exception e) {
throw new IOException("fail to close tableClient" , e);
}
OB_TABLE_CLIENT_INSTANCE.clear();
}

public static class ObTableClientKey {
private String paramUrl;
private String fullUserName;
Expand Down