开发者社区 问答 正文

flinksql的udf中可以使用Operator state的api么?

通过flinksql读kafka数据流,实现监控用户信息基于上一次状态值发生变更触发最新用户信息输出.*来自志愿者整理的flink邮件归档

展开
收起
EXCEED 2021-12-02 15:57:55 807 分享 版权
1 条回答
写回答
取消 提交回答
  • SQL 目前并不支持 stateful udf,你可能需要通过 data stream api 来完成这个需求,详见文档

    https://ci.apache.org/projects/flink/flink-docs-release-1.13/zh/docs/dev/datastream/operators/process_function/*来自志愿者整理的FLINK邮件归档

    2021-12-02 16:11:34
    赞同 展开评论