table.incrementColumnValue这个函数的作用是什么？不太理解

来源：7-18 需求三功能实现

BillyWebber

2021-01-04

logStream.map(x => {
  ((x._1,x._3), x._2)
}).reduceByKey(_+_)
  .foreachRDD(rdd => {
    rdd.foreachPartition(partition => {
      val table = HBaseClient.getTable("access_user_hour")
      partition.foreach(x => {
        table.incrementColumnValue(
          (x._1._1+"_"+x._1._2).getBytes,
          "o".getBytes,
          "time".getBytes,
          x._2
        )
      })
      table.close()
    })
  })

课程7-18的这段代码里面，视频上说下一个批次也会存在同样key的值，因此需要追加进去，您说的追加是什么意思？是覆盖掉之前那个批次的同样key的value值吗？

写回答

1回答