AI 助理
备案控制台
开发者社区 问答 正文

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

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

展开
收起
EXCEED 2021-12-02 15:57:55 810 分享 版权

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

1 条回答
写回答
取消 提交回答
  • 彗星halation

    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
    赞同 展开评论
问答分类：
消息中间件 监控 Kafka API 流计算 实时计算 Flink版 云消息队列 Kafka 版
问答标签：
udf API API udf API operator state API API state
问答地址：
开发者社区 > 微服务 > 问答
相关问答
在大数据计算MaxCompute中如果通过udf去访问高德api，参数配置页签的外部网络中如何配置？
113
1
0
在大数据计算MaxCompute中如果通过udf去访问高德api，参数配置页签的外部网络中如何配置？
92
0
0
大数据计算MaxCompute中UDF可以调用阿里云的内网IP的API吗？
133
1
0
大数据计算MaxCompute想封装一个访问通义千问API的UDF，它还依赖好多的包，为什么？
102
2
0
我想问一下大数据计算MaxCompute，python Udf 并发访问api 时，有并发但是感觉？
127
1
0
大数据计算MaxCompute现在构建的UDF，需要调用一个阿里云内网的api我该如何获取？
139
3
0
我现在构建的UDF，需要调用一个阿里云内网的api
134
2
0
请教一下，如何用state processor api解析SplitEnumerator的状态信息啊
281
1
0
State Processor API # ------这个只能离线批处理吗？？
724
1
0
有没有大佬知道，flink1.12使用state process api做状态迁移，实际读取的sp路
650
1
0