--- ThriftServer.java 2011-08-03 15:14:40.000000000 +0800 +++ ThriftServer.java.raw 2011-08-03 15:11:34.000000000 +0800 @@ -376,7 +376,7 @@ HTable table = getTable(tableName); if (columns == null) { Get get = new Get(row); - get.setTimeStamp(timestamp); + get.setTimeRange(Long.MIN_VALUE, timestamp); Result result = table.get(get); return ThriftUtilities.rowResultFromHBase(result); } @@ -390,7 +390,7 @@ get.addColumn(famAndQf[0], famAndQf[1]); } } - get.setTimeStamp(timestamp); + get.setTimeRange(Long.MIN_VALUE, timestamp); Result result = table.get(get); return ThriftUtilities.rowResultFromHBase(result); } catch (IOException e) { @@ -690,7 +690,7 @@ try { HTable table = getTable(tableName); Scan scan = new Scan(startRow); - scan.setTimeStamp(timestamp); + scan.setTimeRange(Long.MIN_VALUE, timestamp); if(columns != null && columns.size() != 0) { for(byte [] column : columns) { byte [][] famQf = KeyValue.parseColumn(column); @@ -713,7 +713,7 @@ try { HTable table = getTable(tableName); Scan scan = new Scan(startRow, stopRow); - scan.setTimeStamp(timestamp); + scan.setTimeRange(Long.MIN_VALUE, timestamp); if(columns != null && columns.size() != 0) { for(byte [] column : columns) { byte [][] famQf = KeyValue.parseColumn(column); @@ -724,7 +724,7 @@ } } } - scan.setTimeStamp(timestamp); + scan.setTimeRange(Long.MIN_VALUE, timestamp); return addScanner(table.getScanner(scan)); } catch (IOException e) { throw new IOError(e.getMessage());