【发布时间】:2018-10-02 05:24:09
【问题描述】:
BigQueryIO.Read 函数将返回 TableRow 的 PCollection,但我如何获取刚刚运行的查询的作业 ID?
可能有一种方法可以传入自定义作业 ID,但我想知道是否有任何方法可以从数据流作业信息本身中读取此信息。
【问题讨论】:
标签: google-cloud-dataflow apache-beam
BigQueryIO.Read 函数将返回 TableRow 的 PCollection,但我如何获取刚刚运行的查询的作业 ID?
可能有一种方法可以传入自定义作业 ID,但我想知道是否有任何方法可以从数据流作业信息本身中读取此信息。
【问题讨论】:
标签: google-cloud-dataflow apache-beam