时间戳

首页 > 解决方案 > 在 KSQL 中定义模式时如何处理重复的列名

apache-kafka - 在 KSQL 中定义模式时如何处理重复的列名

问题描述

如何在定义架构时处理重复的列名。在下面的代码中，尝试SOURCES为 SOURCES_ARRAY. 由于我们无法为列名称加上别名，因此出现错误。任何帮助，将不胜感激。

create stream example
(with topic='example_topic',value_format='JSON')
(changeType varchar,
domain varchar,
id varchar,
payload struct<id varchar,
                domain varchar,
                rootState varchar, 
                sources array<struct< 
                        source varchar,
                        domain varchar, ETC >>>,
payload struct<sources array<varchar) as sources_array;

标签： apache-kafkaapache-kafka-streamsconfluent-platformksqldb

解决方案

推荐阅读