我想在flinkapi中获得资源管理的方法（比如init、close）。如。当我向flink提交一个作业时，一些jdbc连接就建立起来了。当我取消作业时，这些连接在作业取消之前关闭。
aurhwmvo1#
这个 RichFunction 接口提供 open() 以及 close() 方法。 open() 在任务启动时和处理第一条记录之前调用。 close() 由于失败或故意取消任务时调用。对于大多数函数，都有一个丰富的变体，即， RichMapFunction 为了 MapFunction .
RichFunction
open()
close()
RichMapFunction
MapFunction
1条答案
按热度按时间aurhwmvo1#
这个
RichFunction接口提供open()以及close()方法。open()在任务启动时和处理第一条记录之前调用。close()由于失败或故意取消任务时调用。对于大多数函数，都有一个丰富的变体，即，
RichMapFunction为了MapFunction.