2017-05-04 64 views
0

缺省情況下,Hbase具有每行的時間戳值。我們如何通過spark scala代碼在HBase中更新我自己的時間戳值,同時保存(插入)來自Spark Dataframe的記錄?需要根據列自己的值更新Hbase中的時間戳,但不是默認時間戳

例如,

create 'test', 'cf' 

put 'test', 'row1', 'cf:a', 'value1' 

put 'test', 'row2', 'cf:b', 'value2' 

put 'test', 'row3', 'cf:c', 'value3' 

scan 'test' 

ROW COLUMN+CELL 

row1 column=cf:a, timestamp=1288380727188, value=value1 

row2 column=cf:b, timestamp=1288380738440, value=value2 

row3 column=cf:c, timestamp=1288380747365, value=value3 

我們如何更新時間戳基於我們的數據幀?

回答

0

您可以在末尾添加你想加入龍時間戳: 把「測試」,「ROW1」,「CF:一」,「值1,1111111

如果要更新的時間戳,你只需要再次添加相同的數據(如果你有版本= 1,但這是其他問題)