Index: src/main/java/org/apache/hadoop/hbase/thrift/ThriftServer.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/thrift/ThriftServer.java (revision 1153295) +++ src/main/java/org/apache/hadoop/hbase/thrift/ThriftServer.java (working copy) @@ -408,7 +408,7 @@ HTable table = getTable(tableName); if (columns == null) { Get get = new Get(getBytes(row)); - get.setTimeRange(Long.MIN_VALUE, timestamp); + get.setTimeStamp(timestamp); Result result = table.get(get); return ThriftUtilities.rowResultFromHBase(result); } @@ -421,7 +421,7 @@ get.addColumn(famAndQf[0], famAndQf[1]); } } - get.setTimeRange(Long.MIN_VALUE, timestamp); + get.setTimeStamp(timestamp); Result result = table.get(get); return ThriftUtilities.rowResultFromHBase(result); } catch (IOException e) { @@ -472,7 +472,7 @@ get.addColumn(famAndQf[0], famAndQf[1]); } } - get.setTimeRange(Long.MIN_VALUE, timestamp); + get.setTimeStamp(timestamp); } gets.add(get); } @@ -831,7 +831,7 @@ try { HTable table = getTable(tableName); Scan scan = new Scan(getBytes(startRow)); - scan.setTimeRange(Long.MIN_VALUE, timestamp); + scan.setTimeStamp(timestamp); if(columns != null && columns.size() != 0) { for(ByteBuffer column : columns) { byte [][] famQf = KeyValue.parseColumn(getBytes(column)); @@ -855,7 +855,7 @@ try { HTable table = getTable(tableName); Scan scan = new Scan(getBytes(startRow), getBytes(stopRow)); - scan.setTimeRange(Long.MIN_VALUE, timestamp); + scan.setTimeStamp(timestamp); if(columns != null && columns.size() != 0) { for(ByteBuffer column : columns) { byte [][] famQf = KeyValue.parseColumn(getBytes(column)); @@ -866,7 +866,6 @@ } } } - scan.setTimeRange(Long.MIN_VALUE, timestamp); return addScanner(table.getScanner(scan)); } catch (IOException e) { throw new IOError(e.getMessage());