2
4

2 回答 2

0

您需要在投影中创建一个结构（SELECT 部分）

SELECT STRUCT(message_table.device.ID as ID , devices.name as NAME) as device
FROM pubsub.topic.project_id.`topic` as message_table
  JOIN bigquery.table.project_id.dataflow_sql_dataset.devices as devices 
  ON devices.device_id = message_table.device.id
于 2021-05-07T14:16:55.113 回答
0

不幸的是，Dataflow SQL 目前不支持 STRUCT/Sub 查询，但我们正在努力。由于有一些 Apache Beam 依赖项阻碍了其进展（嵌套行支持、升级方解石），我们目前无法提供 ETA，但您可以在此问题跟踪器上关注其进展。

于 2021-06-03T11:02:22.690 回答