如何检查流中是否有两个以上的记录来自同一个userid但具有不同的productid。假设我们有流(uid,pid,price),如果从同一个uid有多个不同的pid,我想发出。如果pid是字符串,正确的查询语法是什么?
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;
1条答案
按热度按时间5us2dqdw1#
使用count\u distinct运算符