@@ -1916,7 +1916,9 @@ private ObTableQuery buildObTableQuery(ObHTableFilter filter, byte[] start,
1916
1916
obTableQuery .setIndexName ("PRIMARY" );
1917
1917
obTableQuery .sethTableFilter (filter );
1918
1918
obTableQuery .addKeyRange (obNewRange );
1919
- obTableQuery .setScanRangeColumns ("K" , "Q" , "T" );
1919
+ if (obTableClient .isOdpMode ()) {
1920
+ obTableQuery .setScanRangeColumns ("K" , "Q" , "T" );
1921
+ }
1920
1922
return obTableQuery ;
1921
1923
}
1922
1924
@@ -1942,7 +1944,9 @@ private ObTableQuery buildObTableQuery(ObHTableFilter filter, final Scan scan) {
1942
1944
: configuration .getLong (HConstants .HBASE_CLIENT_SCANNER_MAX_RESULT_SIZE_KEY ,
1943
1945
HConstants .DEFAULT_HBASE_CLIENT_SCANNER_MAX_RESULT_SIZE ));
1944
1946
obTableQuery .setObKVParams (buildOBKVParams (scan ));
1945
- obTableQuery .setScanRangeColumns ("K" , "Q" , "T" );
1947
+ if (obTableClient .isOdpMode ()) {
1948
+ obTableQuery .setScanRangeColumns ("K" , "Q" , "T" );
1949
+ }
1946
1950
return obTableQuery ;
1947
1951
}
1948
1952
@@ -1959,7 +1963,9 @@ private ObTableQuery buildObTableQuery(final Get get, Collection<byte[]> columnQ
1959
1963
get .getTimeRange ());
1960
1964
}
1961
1965
obTableQuery .setObKVParams (buildOBKVParams (get ));
1962
- obTableQuery .setScanRangeColumns ("K" , "Q" , "T" );
1966
+ if (obTableClient .isOdpMode ()) {
1967
+ obTableQuery .setScanRangeColumns ("K" , "Q" , "T" );
1968
+ }
1963
1969
return obTableQuery ;
1964
1970
}
1965
1971
0 commit comments