fix HBase PrefixFilter bug (#2364)

* #2177 * #2177 * #2177 * #2177 * #2177 * #2177
apache · Nov 29, 2023 · d376b02 · d376b02
1 parent 197e8a0
commit d376b02
Showing 1 changed file with 9 additions and 2 deletions.
diff --git a/...hugegraph-hbase/src/main/java/org/apache/hugegraph/backend/store/hbase/HbaseSessions.java b/...hugegraph-hbase/src/main/java/org/apache/hugegraph/backend/store/hbase/HbaseSessions.java
@@ -415,11 +415,18 @@ default R scan(String table, Set<byte[]> prefixes) {
 
         /**
          * Scan records by rowkey start and prefix from a table
+         * TODO: setRowPrefixFilter deprecated since HBase 2.5.0, will be removed in 4.0.0,
+         * use setStartStopRowForPrefixScan(byte[]) instead.
          */
         default R scan(String table, byte[] startRow, boolean inclusiveStart,
                        byte[] prefix) {
-            Scan scan = new Scan().withStartRow(startRow, inclusiveStart)
-                                  .setFilter(new PrefixFilter(prefix));
+            final Scan scan = new Scan();
+            if(startRow == prefix) {
+                scan.setRowPrefixFilter(prefix);
+            } else {
+                scan.withStartRow(startRow, inclusiveStart)
+                    .setFilter(new PrefixFilter(prefix));
+            }
             return this.scan(table, scan);
         }