time range

Author: miyuan-ljr

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

@@ -38,6 +38,7 @@
 import com.alipay.oceanbase.rpc.stream.ObTableClientQueryAsyncStreamResult;
 import com.alipay.oceanbase.rpc.table.ObHBaseParams;
 import com.alipay.oceanbase.rpc.table.ObKVParams;
+import com.alipay.oceanbase.rpc.util.ObBytesString;
 import com.alipay.sofa.common.thread.SofaThreadPoolExecutor;
 
 import com.google.protobuf.Descriptors;
@@ -994,6 +995,9 @@ private ObKVParams buildOBKVParams(final Scan scan) {
             obHBaseParams.setCallTimeout(scannerTimeout);
             obHBaseParams.setCacheBlock(scan.isGetScan());
             obHBaseParams.setAllowPartialResults(scan.getAllowPartialResults());
+            for (Map.Entry<byte[], TimeRange> entry: scan.getColumnFamilyTimeRange().entrySet()) {
+                obHBaseParams.addFamilyTimeRange(new ObBytesString(entry.getKey()), entry.getValue().getMin(), entry.getValue().getMax());
+            }
         }
         obKVParams.setObParamsBase(obHBaseParams);
         return obKVParams;
@@ -1004,6 +1008,9 @@ private ObKVParams buildOBKVParams(final Get get) {
         ObHBaseParams obHBaseParams = new ObHBaseParams();
         obHBaseParams.setCheckExistenceOnly(get.isCheckExistenceOnly());
         obHBaseParams.setCacheBlock(get.getCacheBlocks());
+        for (Map.Entry<byte[], TimeRange> entry: get.getColumnFamilyTimeRange().entrySet()) {
+            obHBaseParams.addFamilyTimeRange(new ObBytesString(entry.getKey()), entry.getValue().getMin(), entry.getValue().getMax());
+        }
         obKVParams.setObParamsBase(obHBaseParams);
         return obKVParams;
     }