我正在使用 Go 库写入 BigTable。我使用该ApplyBulk
方法以原子方式进行多次插入。但是,当我使用该函数查询 BigTable 时,ReadRows
我看到具有相同行键的多个副本/版本。
例如:在下面提到的示例中,我看到同一 RowKey 的多个副本包含部分数据,最后一次出现的副本包含包含所有字段的所有列。
如何确保每个行键只存储一个数据副本?如何仅获取插入的行的最新版本?
代码:
row_range := bigtable.PrefixRange("")
err = tbl.ReadRows(ctx,row_range, func(row bigtable.Row) bool {
// logic goes here
}, bigtable.RowFilter(bigtable.LatestNFilter(1)))
森林海
萧十郎
MMTTMM
相关分类