hbase 取多个版本数据

http://jiajun.iteye.com/blog/945358

HBase如何存取多个版本的值？

废话少说，一般情况下使用Put的这个方法保存一个版本：

Java代码

1. /**
2. *AddthespecifiedcolumnandvaluetothisPutoperation.
3. *@paramfamilyfamilyname
4. *@paramqualifiercolumnqualifier
5. *@paramvaluecolumnvalue
6. */
7. publicPutadd(byte[]family,byte[]qualifier,byte[]value){
8. returnadd(family,qualifier,this.timestamp,value);
9. }
11. 然后获取HTable的实例，调用Put方法，更新入库。

这里我要刻意说明一下时间戳 ，可以看到上面的add方面实现里面调用了另外一个方法，增加了个参数：默认时间戳

Java代码

1. this.timestamp

它的值是：

Java代码

1. privatelongtimestamp=HConstants.LATEST_TIMESTAMP;
3. staticfinallongLATEST_TIMESTAMP=Long.MAX_VALUE;

那么获取的时候，获取一个值 也很简单，使用下面的方法：

Java代码

1. 创建一个Put的实例
2. /**
3. *CreateaGetoperationforthespecifiedrow.
4. *<p>
5. *Ifnofurtheroperationsaredone,thiswillgetthelatestversionof
6. *allcolumnsinallfamiliesofthespecifiedrow.
7. *@paramrowrowkey
8. */
9. publicGet(byte[]row){
10. this(row,null);
11. }
13. 然后获取HTable实例调用方法
14. publicResultget(finalGetget)throwsIOException
16. 返回的Result对象调用
17. publicbyte[]getValue(byte[]family,byte[]qualifier)
19. 就可以获取值。

一般的应用可以像上面这样来解决，服务器正常的话不会碰到什么问题，可是要存取多个版本 的话，有可能你会遇到我遇到的问题。 看下面一段代码是否有问题 ？

（里面有如何插入多个版本 ，如何获取多个版本 的方法，顺带说明一个问题）

Java代码

1. /**
2. *Testgetvalueofmultiversions
3. *
4. *@authordev-cjj
5. *
6. */
7. publicclassGetRowVersionsTestextendsTestCase
8. {
9. privatefinalbyte[]family=Bytes.toBytes("log");
11. privatefinalbyte[]qualifier=Bytes.toBytes("q1");
13. privatefinalbyte[]qualifier2=Bytes.toBytes("q2");
15. privatefinalbyte[]rowKey=Bytes.toBytes(10001);
17. privatefinalHTabletable=IDMHBaseConfiguration.getTable("testTable");
19. privatefinallongts1=1298529542218L;
21. privatefinallongts2=ts1+100;
23. privatefinallongts3=ts1+1000;
25. privatefinallongts4=ts1+2000;
27. privatefinallongts5=ts1+3000;
29. privatefinalbyte[]value1=Bytes.toBytes("value1");
31. privatefinalbyte[]value2=Bytes.toBytes("value2");
33. privatefinalbyte[]value3=Bytes.toBytes("value3");
35. privatefinalbyte[]value4=Bytes.toBytes("value4");
37. privatefinalbyte[]value5=Bytes.toBytes("value5");
39. privatevoidinsert(finallongts,finalbyte[]value)throwsIOException
40. {
41. //table.setAutoFlush(false);
42. finalPutput=newPut(rowKey);
43. put.add(family,qualifier,ts,value);
44. put.add(family,qualifier2,ts,value);
45. table.put(put);
46. }
48. privatevoidsleep()
49. {
50. try
51. {
52. Thread.sleep(1000);
53. }
54. catch(finalInterruptedExceptione)
55. {
56. e.printStackTrace();
57. }
58. }
60. @Test
61. publicvoidtestGetRowMultipleVersions()throwsException
62. {
63. insert(ts1,value1);
64. sleep();
65. insert(ts2,value2);
66. sleep();
67. insert(ts3,value3);
68. sleep();
69. insert(ts4,value4);
70. sleep();
71. insert(ts5,value5);
72. sleep();
74. //checkgetRowwithmultipleversions
75. finalGetget=newGet(rowKey);
76. get.setMaxVersions();
77. finalResultr=table.get(get);
79. //onewaygetvaluesofallversion
80. //finalList<KeyValue>list=r.list();
81. //for(finalKeyValuekv:list)
82. //{
83. //System.err.println(Bytes.toString(kv.getKey()));
84. //System.err.println(kv.getTimestamp());
85. //System.err.println(Bytes.toString(kv.getValue()));
86. //}
88. //anotherwaygetvaluesofallversion
89. finalNavigableMap<byte[],NavigableMap<byte[],NavigableMap<Long,byte[]>>>map=r.getMap();
90. finalNavigableMap<byte[],NavigableMap<Long,byte[]>>familyMap=map.get(family);
91. finalNavigableMap<Long,byte[]>versionMap=familyMap.get(qualifier);
92. for(finalMap.Entry<Long,byte[]>entry:versionMap.entrySet())
93. {
94. System.err.println(Bytes.toString(qualifier)+"->"+Bytes.toString(entry.getValue()));
95. }
97. finalNavigableMap<Long,byte[]>versionMap2=familyMap.get(qualifier2);
98. for(finalMap.Entry<Long,byte[]>entry:versionMap2.entrySet())
99. {
100. System.err.println(Bytes.toString(qualifier2)+"->"+Bytes.toString(entry.getValue()));
101. }
103. //assertTrue(versionMap.size()==5);
105. //assertTrue(value1==versionMap.get(ts1));
106. //assertTrue(value2==versionMap.get(ts2));
107. //assertTrue(value3==versionMap.get(ts3));
109. //table.delete(newDelete(rowKey));
111. //assertTrue(table.get(get).size()==0);
112. //table.close();
113. }
114. }

这里我只是打印输出结果 ，不用断言, 结果如你所期望的是：

Java代码

1. q1->value5
2. q1->value4
3. q1->value3
4. q1->value2
5. q1->value1
6. q2->value5
7. q2->value4
8. q2->value3
9. q2->value2
10. q2->value1

上面的代码中，我注视掉了一个关键行

Java代码

1. //table.delete(newDelete(rowKey));

如果取消注释，再运行几次你会发现一个大问题！ 保存不上了，一个版本都没有。

final Result r = table.get(get); 里面什么都不会有！ 很奇怪！

问题原因 （针对上面的代码和问题）：

1、插入的时候使用的时间戳都是过去的时间戳。

2、删除的时候没有指定时间戳（如果没有指定则默认一个当前的时间戳）

3、在HBase中删除操作并没有删除对应的文件，只是做一个带有时间戳的删除标记（任何在这个时间戳之前的列值都会被认为是删除的）

那么知道上面三条规则，问题就简单了，新插入的列值的时间戳要在删除标记的时间戳之后，才会被认为是不被删除的列值。

补充一点，创建/添加列族时候默认是三个版本，可以修改为1个版本或者更多个版本，我上面5个版本是因为我指定了5个版本。

Java代码

1. {NAME=>'testTable',FAMILIES=>[{NAME=>'log',COMPRESSION=>'NONtrue
2. E',VERSIONS=>'5',TTL=>'2147483647',BLOCKSIZE=>'65536',IN_MEM
3. ORY=>'false',BLOCKCACHE=>'true'}]}