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

Flink API中的ProcessFunctions的作用是什么？

Flink API中的ProcessFunctions的作用是什么？

展开
收起
游客k7rjnht6hbtk6 2021-12-10 20:01:43 282 分享 版权

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

1 条回答
写回答
取消 提交回答
  • 游客daliwbfb2wo66

    ProcessFunctions最具表现力但是简洁性最差，是最底层的抽象API，他被主要用来处理包含单独事件的一个或两个输入流或者是分组到一个窗口类的事件，所以提供了对时间和状态的细粒度控制。ProcessFunctions可强制修改state、重注册未来某时触发回调函数的timer，所以可以实现复杂事件处理逻辑，这正适合很多有状态的事件驱动应用程序。

    2021-12-10 20:02:27
    赞同 展开评论
问答分类：
API 流计算 实时计算 Flink版
问答标签：
实时计算 Flink版api API flink 实时计算 Flink版 api
问答地址：
开发者社区 > 大数据 > 问答
相关问答
下flink cdc mysql api的时间字段的问题怎么解决？
649
0
0
flink怎么判断全量已经跑完了，开始走增量的数据处理逻辑呢？有没有什么api可以知道的或者怎么打个
1169
4
0
flink有api可以像 spark那样批出 kafka数据吗？
946
6
0
谁遇到过这个问题，flink 版本1.14.2，table api 查询是可以的。写入目标库的时候既
699
1
0
Flink支持的特性中API支持什么？
550
1
0
这个API那个公共参数不就8个吗？后面然后跟上调用接口的参数对面？
1039
0
0
FC的域名管理有API接口吗？
1052
1
0
咨询一个问题， jindofs 可以提供本地 oss api 接口吗？ 相当于在本地提供一个 oss
1093
1
0
调用API接口 ListTaskFlow调试 , 需要什么权限的账号才能调用 ?
1087
1
0
问一下 调图片识别api接口 报这个错是啥意思
1227
2
0