update hbase to 2.0

Author: miyuan-ljr

pom.xml

@@ -46,7 +46,7 @@
 
     <properties>
         <hadoop.version>2.5.1</hadoop.version>
-        <hbase.version>1.3.6</hbase.version>
+        <hbase.version>2.0.6</hbase.version>
         <java.source.version>1.8</java.source.version>
         <java.target.version>1.8</java.target.version>
         <junit.version>4.13.1</junit.version>

src/main/java/com/alipay/oceanbase/hbase/OHTable.java

@@ -37,7 +37,7 @@
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.locks.ReentrantLock;
 
-public class OHTableClient implements HTableInterface, Lifecycle {
+public class OHTableClient implements Table, Lifecycle {
     private byte[]              tableName;
     private String              tableNameString;
     private ReentrantLock       lock        = new ReentrantLock();
@@ -140,36 +140,6 @@ private void checkStatus() throws IllegalStateException {
         }
     }
 
-    @Override
-    public void setAutoFlush(boolean autoFlush) {
-        checkStatus();
-        ohTable.setAutoFlush(autoFlush);
-    }
-
-    @Override
-    public void setAutoFlush(boolean autoFlush, boolean clearBufferOnFail) {
-        checkStatus();
-        ohTable.setAutoFlush(autoFlush, clearBufferOnFail);
-    }
-
-    @Override
-    public void setAutoFlushTo(boolean autoFlush) {
-        checkStatus();
-        ohTable.setAutoFlushTo(autoFlush);
-    }
-
-    @Override
-    public long getWriteBufferSize() {
-        checkStatus();
-        return ohTable.getWriteBufferSize();
-    }
-
-    @Override
-    public void setWriteBufferSize(long writeBufferSize) throws IOException {
-        checkStatus();
-        ohTable.setWriteBufferSize(writeBufferSize);
-    }
-
     @Override
     public <R extends Message> Map<byte[], R> batchCoprocessorService(Descriptors.MethodDescriptor methodDescriptor,
                                                                       Message request,
@@ -227,11 +197,6 @@ public int getRpcTimeout() {
         return ohTable.getRpcTimeout();
     }
 
-    @Override
-    public byte[] getTableName() {
-        return tableName;
-    }
-
     @Override
     public TableName getName() {
         return ohTable.getName();
@@ -250,6 +215,11 @@ public HTableDescriptor getTableDescriptor() throws IOException {
         return ohTable.getTableDescriptor();
     }
 
+    @Override
+    public TableDescriptor getDescriptor() throws IOException {
+        return null;
+    }
+
     @Override
     public boolean exists(Get get) throws IOException {
         checkStatus();
@@ -263,7 +233,7 @@ public boolean[] existsAll(List<Get> list) throws IOException {
     }
 
     @Override
-    public Boolean[] exists(List<Get> gets) throws IOException {
+    public boolean[] exists(List<Get> gets) throws IOException {
         checkStatus();
         return ohTable.exists(gets);
     }
@@ -276,13 +246,6 @@ public void batch(List<? extends Row> actions, Object[] results) throws IOExcept
         ohTable.batch(actions, results);
     }
 
-    // Not support.
-    @Override
-    public Object[] batch(List<? extends Row> actions) throws IOException, InterruptedException {
-        checkStatus();
-        return ohTable.batch(actions);
-    }
-
     @Override
     public <R> void batchCallback(List<? extends Row> actions, Object[] results,
                                   Batch.Callback<R> callback) throws IOException,
@@ -291,14 +254,6 @@ public <R> void batchCallback(List<? extends Row> actions, Object[] results,
         ohTable.batchCallback(actions, results, callback);
     }
 
-    @Override
-    public <R> Object[] batchCallback(List<? extends Row> actions, Batch.Callback<R> callback)
-                                                                                              throws IOException,
-                                                                                              InterruptedException {
-        checkStatus();
-        return ohTable.batchCallback(actions, callback);
-    }
-
     @Override
     public Result get(Get get) throws IOException {
         checkStatus();
@@ -311,13 +266,6 @@ public Result[] get(List<Get> gets) throws IOException {
         return ohTable.get(gets);
     }
 
-    // Not support.
-    @Override
-    public Result getRowOrBefore(byte[] row, byte[] family) throws IOException {
-        checkStatus();
-        return ohTable.getRowOrBefore(row, family);
-    }
-
     @Override
     public ResultScanner getScanner(Scan scan) throws IOException {
         checkStatus();
@@ -423,25 +371,6 @@ public long incrementColumnValue(byte[] row, byte[] family, byte[] qualifier, lo
         return ohTable.incrementColumnValue(row, family, qualifier, amount, durability);
     }
 
-    @Override
-    public long incrementColumnValue(byte[] row, byte[] family, byte[] qualifier, long amount,
-                                     boolean writeToWAL) throws IOException {
-        checkStatus();
-        return ohTable.incrementColumnValue(row, family, qualifier, amount, writeToWAL);
-    }
-
-    @Override
-    public boolean isAutoFlush() {
-        checkStatus();
-        return ohTable.isAutoFlush();
-    }
-
-    @Override
-    public void flushCommits() throws IOException {
-        checkStatus();
-        ohTable.flushCommits();
-    }
-
     public String getTableNameString() {
         return tableNameString;
     }