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


有什么好的实现方式没?

回复