无法读取查询结果并将其写回 BigQuery

Question

我正在使用 BigQueryIO.readTableRows().fromQuery(...) 从 BigQuery 读取行，然后使用 BigQueryIO.writeTableRows() 将 TableRow 写回 BigQuery。我已经创建了具有正确架构的表，因此使用 CreateDisposition.CREATE_NEVER 并且不必在 Beam 客户端中设置架构。问题是所有Record 字段在查询结果中都被展平（下划线附加），并且与不是展平形式的表的架构不匹配。在读取时使用.withoutResultFlattening() 无助于整理记录，因此无法解决这种差异。我们如何在不展平结果的情况下进行查询？

Answer 1

您可以使用标准 SQL，因为结果不会像 here 解释的那样被展平。