@@ -1927,9 +1927,7 @@ private ObTableQuery buildObTableQuery(ObHTableFilter filter, byte[] start,
1927
1927
obTableQuery .setIndexName ("PRIMARY" );
1928
1928
obTableQuery .sethTableFilter (filter );
1929
1929
obTableQuery .addKeyRange (obNewRange );
1930
- if (obTableClient .isOdpMode ()) {
1931
- obTableQuery .setScanRangeColumns ("K" , "Q" , "T" );
1932
- }
1930
+ obTableQuery .setScanRangeColumns ("K" , "Q" , "T" );
1933
1931
return obTableQuery ;
1934
1932
}
1935
1933
@@ -1956,9 +1954,7 @@ private ObTableQuery buildObTableQuery(ObHTableFilter filter, final Scan scan) {
1956
1954
: configuration .getLong (HConstants .HBASE_CLIENT_SCANNER_MAX_RESULT_SIZE_KEY ,
1957
1955
HConstants .DEFAULT_HBASE_CLIENT_SCANNER_MAX_RESULT_SIZE ));
1958
1956
obTableQuery .setObKVParams (buildOBKVParams (scan ));
1959
- if (obTableClient .isOdpMode ()) {
1960
- obTableQuery .setScanRangeColumns ("K" , "Q" , "T" );
1961
- }
1957
+ obTableQuery .setScanRangeColumns ("K" , "Q" , "T" );
1962
1958
return obTableQuery ;
1963
1959
}
1964
1960
@@ -1984,9 +1980,7 @@ private ObTableQuery buildObTableQuery(final Get get, Collection<byte[]> columnQ
1984
1980
get .getTimeRange ());
1985
1981
}
1986
1982
obTableQuery .setObKVParams (buildOBKVParams (get ));
1987
- if (obTableClient .isOdpMode ()) {
1988
- obTableQuery .setScanRangeColumns ("K" , "Q" , "T" );
1989
- }
1983
+ obTableQuery .setScanRangeColumns ("K" , "Q" , "T" );
1990
1984
return obTableQuery ;
1991
1985
}
1992
1986
0 commit comments