我的目标是添加一些字段并将数据流式传输到BigQuery中。 我的第一种方法是change the File Struct并将更新后的Structs流式传输到BigQuery。这看起来像是一条死路,我正在尝试使用建议的方法,将结构编组到JSON中,并将其流传输到BigQuery中。我找到了这个示例bigquery-table-insert-rows,但它实现了ValueSaver接口。对我来说,一个简单的马歇尔,然后
我使用tabledata().insertAll()方法将我的数据流式传输到BigQuery。数据从TaskQueue发送,异步发送并发数据到一个表。全部通过成功,但并非所有数据在给定表中都可用。我的问题是如何将数据异步导出到BigQuery?我使用以下代码将数据导出到BigQuery:
val content = TableDataInsertAllRequest().setRo