ksql的不同值

2cmtqfgy  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(368)

如何检查流中是否有两个以上的记录来自同一个userid但具有不同的productid。假设我们有流(uid,pid,price),如果从同一个uid有多个不同的pid,我想发出。如果pid是字符串,正确的查询语法是什么?

5us2dqdw

5us2dqdw1#

使用count\u distinct运算符

SELECT COUNT_DISTINCT(PID), uid
 FROM product_stream WINDOW TUMBLING (SIZE 5 SECONDS) GROUP BY uid
 HAVING COUNT_DISTINCT(PID) > 1 EMIT CHANGES;

相关问题