diff --git a/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/ObTableQuery.java b/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/ObTableQuery.java index 7dfa14b5..acac0d8e 100644 --- a/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/ObTableQuery.java +++ b/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/ObTableQuery.java @@ -622,4 +622,8 @@ public void setHotOnly(boolean hotOnly) { public void setGetOptimized(boolean getOptimized) { this.flag.setGetOptimized(getOptimized); } + + public void setQueryWithSingleQualifierHint(boolean queryWithSingleQualifierHint) { + this.flag.setQueryWithSingleQualifierHint(queryWithSingleQualifierHint); + } } diff --git a/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/ObTableQueryFlag.java b/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/ObTableQueryFlag.java index 4008a23b..87683383 100644 --- a/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/ObTableQueryFlag.java +++ b/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/ObTableQueryFlag.java @@ -20,6 +20,7 @@ public class ObTableQueryFlag { private static final int HOT_ONLY = 1 << 0; private static final int GET_OPTIMIZED = 1 << 1; + private static final int QUERY_WITH_SINGLE_QUALIFIER_HINT = 1 << 2; private long value = 0; @@ -54,4 +55,14 @@ public void setGetOptimized(boolean getOptimized) { value = value | GET_OPTIMIZED; } } + + public boolean isQueryWithSingleQualifierHint() { + return (value & QUERY_WITH_SINGLE_QUALIFIER_HINT) != 0; + } + + public void setQueryWithSingleQualifierHint(boolean queryWithSingleQualifierHint) { + if (queryWithSingleQualifierHint) { + value = value | QUERY_WITH_SINGLE_QUALIFIER_HINT; + } + } };