You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by andrew <15...@163.com> on 2022/07/25 14:37:03 UTC

Flinksql 计算特征标签自身状态变化

Dear Flink：
    一需求， FlinkSQL可以用udf实现，捕获标签值的变化。
    例如： 若当前用户由低端用户变为中端用户或由中端用户变为高端用户，输出只要用户state状态发生变化，结果用户状态打标为1，反之为0；


有什么好的实现方式没?