时间戳

首页 > 解决方案 > BEAM SQL 和 RECORD 列类型

apache-beam - BEAM SQL 和 RECORD 列类型

问题描述

我正在尝试使用 Beam SQL 将数据文件中的记录选择到 PCollection 中。

我的数据文件具有以下 AVRO 架构：

"name":"str-field", "type":[ "null", "string" ],
"default":null }, { "name":"myRecord", "type":[ "null", { “类型”：“记录”，“名称”：“myRecord”，“字段”：[{“名称”：“stringInRecord”，“类型”：“字符串”}，{“名称”：“intInRecord”，“类型":"int" },

我的 Beam SQL 是这样的：SELECT str-field, myRecord from Datafile

但是，Beam 不会将 myRecord 识别为 RECORD 类型。这里有什么问题吗？或者，是不是 BeamSQL 不支持“RECORD”类型？

标签： apache-beambeam-sql

解决方案

推荐阅读