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
我們如何更新時間戳基於我們的數據幀?