如何解决将查询推送到ksqlDB不会在第一个结果行中返回最终结果
我试图在任意时间窗口内获取ksqlDB表中的事件计数。
表my_table
是用WINDOW SESSION
创建的。
重要的是要注意,查询在处理完所有数据之后才开始运行,而ksqlDB服务器基本上什么也不做。
我的查询看起来像这样
count(*) as count
FROM my_table
WHERE WINDOWSTART < (1602010972370 + 5000) AND WINDOWEND > 1602010972370
group by 1 emit changes;
运行这种查询通常会返回一个结果行,并在第二个结果行之后立即返回实际的“最终”结果。
它看起来好像不是表中的值尚未“解决”的结果,因为如果我重复相同的查询(根据需要多次),则会得到相同的确切行为。
我假设有一些配置值,它将使ksqlDB在返回结果之前稍等一会(大约一秒钟),这样我就可以在第一行中得到最终结果了吗?
使用emit final
的BTW不适用于查询本身,因为它仅适用于“窗口式查询”
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。