File tree Expand file tree Collapse file tree 6 files changed +0
-10
lines changed
src/main/java/com/alipay/oceanbase/rpc Expand file tree Collapse file tree 6 files changed +0
-10
lines changed Original file line number Diff line number Diff line change 4747import com .alipay .remoting .util .StringUtils ;
4848import org .slf4j .Logger ;
4949
50- import javax .sound .midi .SysexMessage ;
5150import java .util .*;
5251import java .util .concurrent .ConcurrentHashMap ;
5352import java .util .concurrent .TimeUnit ;
6564import static com .alipay .oceanbase .rpc .protocol .payload .ResultCodes .OB_ERR_KV_ROUTE_ENTRY_EXPIRE ;
6665import static com .alipay .oceanbase .rpc .protocol .payload .impl .execute .ObTableOperationType .*;
6766import static com .alipay .oceanbase .rpc .util .TableClientLoggerFactory .*;
68- import static java .lang .String .format ;
6967
7068public class ObTableClient extends AbstractObTableClient implements Lifecycle {
7169 private static final Logger logger = getLogger (ObTableClient .class );
Original file line number Diff line number Diff line change 2121import com .alibaba .fastjson .JSONException ;
2222import com .alibaba .fastjson .JSONObject ;
2323import com .alibaba .fastjson .parser .ParserConfig ;
24- import com .alipay .oceanbase .rpc .ObClusterTableBatchOps ;
2524import com .alipay .oceanbase .rpc .ObGlobal ;
2625import com .alipay .oceanbase .rpc .constant .Constants ;
2726import com .alipay .oceanbase .rpc .exception .*;
Original file line number Diff line number Diff line change 1717
1818package com .alipay .oceanbase .rpc .stream ;
1919
20- import com .alipay .oceanbase .rpc .ObGlobal ;
2120import com .alipay .oceanbase .rpc .ObTableClient ;
2221import com .alipay .oceanbase .rpc .bolt .transport .ObTableConnection ;
2322import com .alipay .oceanbase .rpc .exception .ObTableException ;
2423import com .alipay .oceanbase .rpc .exception .ObTableNeedFetchAllException ;
2524import com .alipay .oceanbase .rpc .exception .ObTableRetryExhaustedException ;
26- import com .alipay .oceanbase .rpc .location .model .TableEntry ;
2725import com .alipay .oceanbase .rpc .location .model .partition .ObPair ;
2826import com .alipay .oceanbase .rpc .protocol .payload .Constants ;
2927import com .alipay .oceanbase .rpc .protocol .payload .ObPayload ;
3230import com .alipay .oceanbase .rpc .protocol .payload .impl .execute .syncquery .ObTableQueryAsyncRequest ;
3331import com .alipay .oceanbase .rpc .protocol .payload .impl .execute .syncquery .ObTableQueryAsyncResult ;
3432import com .alipay .oceanbase .rpc .table .ObTableParam ;
35- import com .alipay .oceanbase .rpc .util .ByteUtil ;
3633import org .slf4j .Logger ;
3734import org .slf4j .LoggerFactory ;
3835
Original file line number Diff line number Diff line change 1919
2020import com .alipay .oceanbase .rpc .exception .ExceptionUtil ;
2121import com .alipay .oceanbase .rpc .exception .ObTableException ;
22- import com .alipay .oceanbase .rpc .mutation .*;
2322import com .alipay .oceanbase .rpc .mutation .result .*;
2423import com .alipay .oceanbase .rpc .protocol .payload .ResultCodes ;
2524import com .alipay .oceanbase .rpc .protocol .payload .impl .execute .*;
Original file line number Diff line number Diff line change 1717
1818package com .alipay .oceanbase .rpc .table ;
1919
20- import com .alipay .oceanbase .rpc .ObGlobal ;
2120import com .alipay .oceanbase .rpc .ObTableClient ;
2221import com .alipay .oceanbase .rpc .exception .*;
2322import com .alipay .oceanbase .rpc .location .model .ObServerRoute ;
24- import com .alipay .oceanbase .rpc .location .model .TableEntry ;
2523import com .alipay .oceanbase .rpc .location .model .partition .ObPair ;
2624import com .alipay .oceanbase .rpc .mutation .result .*;
2725import com .alipay .oceanbase .rpc .protocol .payload .ObPayload ;
Original file line number Diff line number Diff line change 3333import com .alipay .oceanbase .rpc .table .api .TableQuery ;
3434import com .alipay .oceanbase .rpc .util .MonitorUtil ;
3535
36- import java .util .HashMap ;
3736import java .util .LinkedHashMap ;
3837import java .util .List ;
3938import java .util .Map ;
You can’t perform that action at this time.
0 commit comments