【发布时间】:2021-06-18 15:20:15
【问题描述】:
我从这个查询开始创建了一个流
CREATE TABLE MSG_COUNT_STREAM AS SELECT 1,TIMESTAMPTOSTRING(WINDOWSTART,'yyyy-MM-dd:HH:mm','Europe/London') AS START_TS,
COUNT(*) AS COUNT FROM 'source'
WINDOW TUMBLING (SIZE 60 SECONDS) GROUP BY 1
EMIT CHANGES;
如果我在流上执行选择,我可以正确看到所有字段,如果不是从融合中查看消息的“关键”字段,它是由奇怪的、不可读的字符组成的。我该如何解决? 这是关键
【问题讨论】:
-
你能举个例子吗?
-
我编辑了帖子,问题是表格的键在应用窗口管之后没有可读的格式。是否可以只使用 ksqldb 让窗口翻滚和我选择的键?
-
@dune98,我遇到了同样的问题,您找到解决方案了吗?
-
@deeplay 不抱歉,我认为您必须使用密钥转换类。至少这个奇怪的键是由base_key + window start + window end这样的合并数据产生的。
标签: sql apache-kafka confluent-platform ksqldb