当我尝试在 bigquery 中插入时,我收到此错误“X 行插入失败”,其中 X 是行数。
我在 Golang 中使用这个库“cloud.google.com/go/bigquery”
我在这里附上代码:
u := table.Uploader()
var inserts []*bigquery.StructSaver
for _, insert := range value {
aux := bigquery.StructSaver{Struct: insert, Schema: schema}
inserts = append(inserts, &aux)
}
err := u.Put(ctx, inserts)
if err != nil {
fmt.Printf("%v\n", err)
}
Run Code Online (Sandbox Code Playgroud)
这不会在每次尝试中发生,我不知道是什么可以产生它。有人遇到同样的错误吗?
我正在使用数据包“ org.apache.hadoop.hbase.client”来管理Google的BigTable数据。
删除行的示例:
key = "PROV|CLI|800|20160714|8|30302.30301|ES";
byte[] byteKey = Bytes.toBytes(key);
Delete delete = new Delete(byteKey);
Run Code Online (Sandbox Code Playgroud)
这可以正常工作,但是我需要一种删除以键“ PROV | CLI | 800 |”开头的所有行的方法
反正有这样做吗?
我有一个只有一个列族的表,这个列的TTL为24小时,但我需要在截止日期之前删除一些数据.
为了实现这个目标,我伪造了插入日期.例如:如果我需要在插入后1小时删除一行,我将插入日期设置为23小时前.这个机制运行正常,Bigtable在一小时后删除了我的数据,但我不知道这是否会在Bigtable的内部工作流程中产生错误.
我可以继续使用它还是有其他方法可以做到这一点?