用于不同值的 KSQL

Question

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

Answer 1

使用 count_distinct 运算符

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