Skip to content

Commit b32c7e1

Browse files
committed
add comments
1 parent 24dfa6a commit b32c7e1

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

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

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2103,6 +2103,9 @@ private BatchOperation buildBatchOperation(String tableName, List<? extends Row>
21032103
}
21042104
}
21052105
NavigableSet<byte[]> columnFilters = new TreeSet<>(Bytes.BYTES_COMPARATOR);
2106+
// in batch get, we need to carry family in qualifier to server even this get is a single-cf operation
2107+
// because the entire batch may be a multi-cf batch so do not carry family
2108+
// family in qualifier helps us to know which table to query
21062109
processColumnFilters(columnFilters, get.getFamilyMap());
21072110
obTableQuery = buildObTableQuery(get, columnFilters);
21082111
ObTableClientQueryImpl query = new ObTableClientQueryImpl(tableName, obTableQuery, obTableClient);

0 commit comments

Comments
 (0)