File tree Expand file tree Collapse file tree 3 files changed +4
-7
lines changed
main/java/com/alipay/oceanbase/hbase
test/java/com/alipay/oceanbase/hbase Expand file tree Collapse file tree 3 files changed +4
-7
lines changed Original file line number Diff line number Diff line change 26
26
import com .alipay .oceanbase .rpc .ObTableClient ;
27
27
import com .alipay .oceanbase .rpc .exception .ObTableException ;
28
28
import com .alipay .oceanbase .rpc .location .model .partition .Partition ;
29
- import com .alipay .oceanbase .rpc .exception .ObTableException ;
30
29
import com .alipay .oceanbase .rpc .exception .ObTableUnexpectedException ;
31
30
import com .alipay .oceanbase .rpc .mutation .BatchOperation ;
32
31
import com .alipay .oceanbase .rpc .mutation .result .BatchOperationResult ;
45
44
import com .alipay .oceanbase .rpc .table .ObHBaseParams ;
46
45
import com .alipay .oceanbase .rpc .table .ObKVParams ;
47
46
import com .alipay .oceanbase .rpc .table .ObTableClientQueryImpl ;
48
- import com .alipay .sofa .common .thread .SofaThreadPoolExecutor ;
49
47
50
48
import com .google .protobuf .Descriptors ;
51
49
import com .google .protobuf .Message ;
73
71
import static com .alipay .oceanbase .hbase .constants .OHConstants .*;
74
72
import static com .alipay .oceanbase .hbase .util .Preconditions .checkArgument ;
75
73
import static com .alipay .oceanbase .hbase .util .TableHBaseLoggerFactory .LCD ;
76
- import static com .alipay .oceanbase .hbase .util .TableHBaseLoggerFactory .TABLE_HBASE_LOGGER_SPACE ;
77
74
import static com .alipay .oceanbase .rpc .mutation .MutationFactory .colVal ;
78
75
import static com .alipay .oceanbase .rpc .mutation .MutationFactory .row ;
79
76
import static com .alipay .oceanbase .rpc .protocol .payload .impl .execute .ObTableOperation .getInstance ;
Original file line number Diff line number Diff line change 4
4
5
5
public class CompatibilityUtil {
6
6
public static boolean isBatchSupport () {
7
- return (ObGlobal .OB_VERSION >= ObGlobal .OB_VERSION_4_2_5_1 && ObGlobal .OB_VERSION < ObGlobal .OB_VERSION_4_3_0_0 )
8
- || ObGlobal .OB_VERSION >= ObGlobal .OB_VERSION_4_3_5_0 ;
7
+ return (ObGlobal .OB_VERSION >= ObGlobal .OB_VERSION_4_2_5_2 && ObGlobal .OB_VERSION < ObGlobal .OB_VERSION_4_3_0_0 )
8
+ || ObGlobal .OB_VERSION >= ObGlobal .OB_VERSION_4_3_5_0 ;
9
9
}
10
10
}
Original file line number Diff line number Diff line change 51
51
public abstract class HTableTestBase extends HTableMultiCFTestBase {
52
52
53
53
@ Rule
54
- public ExpectedException expectedException = ExpectedException .none ();
54
+ public ExpectedException expectedException = ExpectedException .none ();
55
55
56
- protected static Table hTable ;
56
+ protected static Table hTable ;
57
57
58
58
private static AtomicInteger count = new AtomicInteger (0 );
59
59
private static AtomicInteger idx = new AtomicInteger (0 );
You can’t perform that action at this time.
0 commit comments