用于不同值的 KSQL

【问题标题】：KSQL for distinct values用于不同值的 KSQL
【发布时间】：2020-11-11 12:10:16
【问题描述】：

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

【问题讨论】：

【解决方案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;

【讨论】：