Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-2738. TestTimeRangeMapRed updated now that we keep multiple cells with same timestamp in MemStore 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@955331 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Todd Lipcon 2010-06-16 18:05:00 +00:00
parent 0af4fd881b
commit d7181bd7c5
2 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
CHANGES.txt
View File

@ -391,6 +391,8 @@ Release 0.21.0 - Unreleased
HBASE-2733 Replacement of LATEST_TIMESTAMP with real timestamp was broken HBASE-2733 Replacement of LATEST_TIMESTAMP with real timestamp was broken
by HBASE-2353. by HBASE-2353.
HBASE-2734 TestFSErrors should catch all types of exceptions, not just RTE HBASE-2734 TestFSErrors should catch all types of exceptions, not just RTE
HBASE-2738 TestTimeRangeMapRed updated now that we keep multiple cells with
same timestamp in MemStore
IMPROVEMENTS IMPROVEMENTS
HBASE-1760 Cleanup TODOs in HTable HBASE-1760 Cleanup TODOs in HTable

4
src/test/java/org/apache/hadoop/hbase/mapreduce/TestTimeRangeMapRed.java
View File

@ -183,14 +183,14 @@ public class TestTimeRangeMapRed extends HBaseClusterTestCase {
private void verify() throws IOException { private void verify() throws IOException {
Scan scan = new Scan(); Scan scan = new Scan();
scan.addColumn(FAMILY_NAME, COLUMN_NAME); scan.addColumn(FAMILY_NAME, COLUMN_NAME);
scan.setMaxVersions(); scan.setMaxVersions(1);
ResultScanner scanner = table.getScanner(scan); ResultScanner scanner = table.getScanner(scan);
for (Result r: scanner) { for (Result r: scanner) {
for (KeyValue kv : r.sorted()) { for (KeyValue kv : r.sorted()) {
assertEquals(TIMESTAMP.get(kv.getTimestamp()), (Boolean)Bytes.toBoolean(kv.getValue()));
log.debug(Bytes.toString(r.getRow()) + "\t" + Bytes.toString(kv.getFamily()) log.debug(Bytes.toString(r.getRow()) + "\t" + Bytes.toString(kv.getFamily())
+ "\t" + Bytes.toString(kv.getQualifier()) + "\t" + Bytes.toString(kv.getQualifier())
+ "\t" + kv.getTimestamp() + "\t" + Bytes.toBoolean(kv.getValue())); + "\t" + kv.getTimestamp() + "\t" + Bytes.toBoolean(kv.getValue()));
assertEquals(TIMESTAMP.get(kv.getTimestamp()), (Boolean)Bytes.toBoolean(kv.getValue()));
} }
} }
scanner.close(); scanner.close();