知识卡片
Rich函数有生命周期
内容
Rich 函数类除了业务方法,还提供 open、close 和 RuntimeContext,适合初始化连接、访问状态和读取运行环境。发散:需要资源管理或上下文时,Lambda(见[[函数式接口承载Lambda]])的轻巧就不够用了。
参考来源
- 位置:《Flink原理与实践》第4章《DataStream API的介绍和使用》(源文件:_epub-src/OEBPS/Text/chapter07.xhtml)
- 结论依据:原文围绕“Rich函数类”给出定义、流程、对比或限制条件,本卡片据此提炼其可迁移的框架机制,并补充了使用边界或工程启发。
- 原始内容:a Lambda表达式定义的对比不难发现,Scala更灵活,Java更严谨,各有优势。 4.4.3 Rich函数类 在上面两种自定义方法的基础上,Flink还提供了RichFunction函数类。从名称上来看,这种接口在普通的接口上增加了Rich前缀,比如RichMapFunction、RichFl……