|
1 | 1 | package com.alipay.oceanbase.hbase.util;
|
2 | 2 |
|
3 | 3 | import com.alibaba.fastjson.JSON;
|
4 |
| -import com.alibaba.fastjson.JSONObject; |
5 | 4 | import com.alipay.oceanbase.hbase.execute.AbstractObTableMetaExecutor;
|
6 | 5 | import com.alipay.oceanbase.rpc.ObTableClient;
|
7 | 6 | import com.alipay.oceanbase.rpc.meta.ObTableMetaRequest;
|
@@ -30,26 +29,27 @@ public ObTableRpcMetaType getMetaType() throws IOException {
|
30 | 29 | }
|
31 | 30 |
|
32 | 31 | @Override
|
33 |
| - public Boolean parse(ObTableMetaResponse response) throws IOException { |
| 32 | + public Void parse(ObTableMetaResponse response) throws IOException { |
| 33 | + return null; |
34 | 34 | }
|
35 | 35 |
|
36 |
| - public void enableTable(String tableName) throws IOException, TableNotFoundException, TableNotEnabledException { |
| 36 | + public Void enableTable(String tableName) throws IOException, TableNotFoundException, TableNotEnabledException { |
37 | 37 | ObTableMetaRequest request = new ObTableMetaRequest();
|
38 | 38 | request.setMetaType(getMetaType());
|
39 | 39 | Map<String, Object> requestData = new HashMap<>();
|
40 | 40 | requestData.put("name", tableName);
|
41 | 41 | String jsonData = JSON.toJSONString(requestData);
|
42 | 42 | request.setData(jsonData);
|
43 |
| - execute(tableClient, request); |
| 43 | + return execute(tableClient, request); |
44 | 44 | }
|
45 | 45 |
|
46 |
| - public void disableTable(String tableName) throws IOException, TableNotFoundException, TableNotDisabledException { |
| 46 | + public Void disableTable(String tableName) throws IOException, TableNotFoundException, TableNotDisabledException { |
47 | 47 | ObTableMetaRequest request = new ObTableMetaRequest();
|
48 | 48 | request.setMetaType(getMetaType());
|
49 | 49 | Map<String, Object> requestData = new HashMap<>();
|
50 | 50 | requestData.put("name", tableName);
|
51 | 51 | String jsonData = JSON.toJSONString(requestData);
|
52 | 52 | request.setData(jsonData);
|
53 |
| - execute(tableClient, request); |
| 53 | + return execute(tableClient, request); |
54 | 54 | }
|
55 | 55 | }
|
0 commit comments