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