【问题标题】:KSQL WINDOW TUMBLING produce strange keyKSQL WINDOW TUMBLING 产生奇怪的键
【发布时间】: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


【解决方案1】:

您可以运行以下命令来检查密钥格式。不过相信你已经想通了,它是按键和窗口的组合。

print MSG_COUNT_STREAM from beginning limit 10;

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 2018-12-27
    • 1970-01-01
    • 1970-01-01
    • 2021-07-26
    • 1970-01-01
    • 2012-01-19
    • 2013-10-08
    • 2019-08-29
    相关资源
    最近更新 更多