scan border bugfix (#97)

Author: stuBirdFly

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

@@ -1466,6 +1466,7 @@ private ObTableQuery buildObTableQuery(ObHTableFilter filter, byte[] start,
         if (Arrays.equals(start, HConstants.EMPTY_BYTE_ARRAY)) {
             obNewRange.setStartKey(ObRowKey.getInstance(ObObj.getMin(), ObObj.getMin(),
                 ObObj.getMin()));
+            obBorderFlag.setInclusiveStart();
         } else if (includeStart) {
             obNewRange.setStartKey(ObRowKey.getInstance(start, ObObj.getMin(), ObObj.getMin()));
             obBorderFlag.setInclusiveStart();
@@ -1477,6 +1478,7 @@ private ObTableQuery buildObTableQuery(ObHTableFilter filter, byte[] start,
         if (Arrays.equals(stop, HConstants.EMPTY_BYTE_ARRAY)) {
             obNewRange.setEndKey(ObRowKey.getInstance(ObObj.getMax(), ObObj.getMax(),
                 ObObj.getMax()));
+            obBorderFlag.setInclusiveEnd();
         } else if (includeStop) {
             obNewRange.setEndKey(ObRowKey.getInstance(stop, ObObj.getMax(), ObObj.getMax()));
             obBorderFlag.setInclusiveEnd();
@@ -1507,11 +1509,11 @@ private ObTableQuery buildObTableQuery(ObHTableFilter filter, final Scan scan) {
             filter.setOffsetPerRowPerCf(scan.getRowOffsetPerColumnFamily());
         }
         if (scan.isReversed()) {
-            obTableQuery = buildObTableQuery(filter, scan.getStopRow(), false, scan.getStartRow(),
-                true, true);
+            obTableQuery = buildObTableQuery(filter, scan.getStopRow(), scan.includeStopRow(), scan.getStartRow(),
+                    scan.includeStartRow(), true);
         } else {
-            obTableQuery = buildObTableQuery(filter, scan.getStartRow(), true, scan.getStopRow(),
-                false, false);
+            obTableQuery = buildObTableQuery(filter, scan.getStartRow(), scan.includeStartRow(), scan.getStopRow(),
+                    scan.includeStopRow(), false);
         }
         if (scan.getBatch() > 0) {
             obTableQuery.setBatchSize(scan.getBatch());

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

@@ -752,7 +752,7 @@ public void batch(List<? extends Row> actions, Object[] results) throws IOExcept
         public <R> void batchCallback(List<? extends Row> actions, Object[] results,
                                       Batch.Callback<R> callback) throws IOException,
                                                                  InterruptedException {
-            throw new FeatureNotSupportedException("not supported yet'");
+            table.batchCallback(actions, results, callback);
         }
 
         @Override