Merge pull request #234 from shenyunlong/local_hbase_compat_3_2.0

[Test] fix test compile error

Author: WeiXinChan

example/simple-hbase-demo/src/main/java/com/oceanbase/example/SimpleHBaseClientDemo.java

@@ -19,6 +19,8 @@
 
 import com.alipay.oceanbase.hbase.OHTableClient;
 import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.hbase.Cell;
+import org.apache.hadoop.hbase.CellUtil;
 import org.apache.hadoop.hbase.client.Get;
 import org.apache.hadoop.hbase.client.Put;
 import org.apache.hadoop.hbase.client.Result;
@@ -49,7 +51,7 @@ public static void simpleTest() throws Exception {
         byte[] rowKey = toBytes("rowKey1");
         byte[] column = toBytes("column1");
         Put put = new Put(rowKey);
-        put.add(family, column, System.currentTimeMillis(), toBytes("value1"));
+        put.addColumn(family, column, System.currentTimeMillis(), toBytes("value1"));
         hTable.put(put);
 
         // 3. get data like hbase
@@ -58,7 +60,7 @@ public static void simpleTest() throws Exception {
         Result r = hTable.get(get);
         if (!r.isEmpty()) {
             Cell cell = r.rawCells()[0];
-            System.out.printf("column1: " + CellUtil.cloneQualifier(r));
+            System.out.printf("column1: " + CellUtil.cloneQualifier(cell));
         }
 
         // 4. close

src/test/java/com/alipay/oceanbase/hbase/secondary/OHTableShareStorageSeriesTest.java

@@ -75,7 +75,7 @@ public static void testGetImpl(String tableName) throws Exception {
         long curTs = System.currentTimeMillis();
         for (int i = 0; i < recordCount; i++) {
             Put put = new Put(toBytes(key + i));
-            put.add(family.getBytes(), (column + i).getBytes(), curTs, toBytes(value + i));
+            put.addColumn(family.getBytes(), (column + i).getBytes(), curTs, toBytes(value + i));
             hTable.put(put);
         }
 
@@ -107,7 +107,7 @@ public static void testScanImpl(String tableName) throws Exception {
         long curTs = System.currentTimeMillis();
         for (int i = 0; i < recordCount; i++) {
             Put put = new Put(toBytes(key + i));
-            put.add(family.getBytes(), (column).getBytes(), curTs, toBytes(value + i));
+            put.addColumn(family.getBytes(), (column).getBytes(), curTs, toBytes(value + i));
             hTable.put(put);
         }
 

src/test/java/com/alipay/oceanbase/hbase/secondary/OHTableShareStorageTest.java

@@ -83,7 +83,7 @@ public static void testGetImpl(String tableName) throws Exception {
         long curTs = System.currentTimeMillis();
         for (int i = 0; i < recordCount; i++) {
             Put put = new Put(toBytes(key + i));
-            put.add(family.getBytes(), (column + i).getBytes(), curTs, toBytes(value + i));
+            put.addColumn(family.getBytes(), (column + i).getBytes(), curTs, toBytes(value + i));
             hTable.put(put);
         }
 
@@ -119,7 +119,7 @@ public static void testMultiCFGetImpl(Map.Entry<String, List<String>> entry) thr
             String family = getColumnFamilyName(tableName);
             for (int i = 0; i < recordCount; i++) {
                 Put put = new Put(toBytes(key + i));
-                put.add(family.getBytes(), (column + i).getBytes(), curTs, toBytes(value + i));
+                put.addColumn(family.getBytes(), (column + i).getBytes(), curTs, toBytes(value + i));
                 hTable.put(put);
             }
         }
@@ -204,7 +204,7 @@ public static void testBatchGetImpl(String tableName) throws Exception {
         long curTs = System.currentTimeMillis();
         for (int i = 0; i < recordCount; i++) {
             Put put = new Put(toBytes(key + i));
-            put.add(family.getBytes(), (column + i).getBytes(), curTs, toBytes(value));
+            put.addColumn(family.getBytes(), (column + i).getBytes(), curTs, toBytes(value));
             hTable.put(put);
         }
 
@@ -245,7 +245,7 @@ public static void testScanImpl(String tableName) throws Exception {
         long curTs = System.currentTimeMillis();
         for (int i = 0; i < recordCount; i++) {
             Put put = new Put(toBytes(key + i));
-            put.add(family.getBytes(), (column).getBytes(), curTs, toBytes(value + i));
+            put.addColumn(family.getBytes(), (column).getBytes(), curTs, toBytes(value + i));
             hTable.put(put);
         }
 
@@ -354,7 +354,7 @@ public static void testMultiCFScanImpl(Map.Entry<String, List<String>> entry) th
             String family = getColumnFamilyName(tableName);
             for (int i = 0; i < recordCount; i++) {
                 Put put = new Put(toBytes(key + i));
-                put.add(family.getBytes(), (column).getBytes(), curTs, toBytes(value));
+                put.addColumn(family.getBytes(), (column).getBytes(), curTs, toBytes(value));
                 hTable.put(put);
             }
         }