知识卡片

Rich函数有生命周期

专业/工作 · 502.f.1

内容

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……