前言祝广大女性节日快乐~快问快答FlinkDataStreamAPI中的RichFunction有哪些用途/特点？RichFunction中获取到的RuntimeContext是干什么用的？所有Function都有对应的RichFunction实现吗？所有Flink流处理的算子都可以传入RichFunction吗？前两个问题实际上可以合并成一个问题。RichFunction的特点是比Function多出了生命周期管理（open()和close()方法），以及能够获取其运行时上下文RuntimeContext。RuntimeContext与Function的每个并行实例（即一个Sub-task）