flink中的JobListeningContext类

2018-10-09  本文已影响0人  北子萌

flink作业上下文监听器——JobListeningContext保存监视正在运行的作业并接收其结果所需的状态。该类下包含有以下几个属性:作业id、应答时间、flink Configuration配置信息、以及类加载器ClassLoader。还有最为重要的两个属性:ActorSystem以及jobClientActor。根据大神的博客知道flink中的ActorSystem用于进行消息的传递和通信。该类中含有一个公有的方法,方法名同类名相同,即为该类的构造函数。

图1

该类中的后半部分代码均为get属性值得方法,以及名为getClassLoader的方法,。用于反序列化作业执行结果中所需的类加载器,决定返回结果还是抛出异常。最后是一个方法是getJobManager(),也是防止出现异常,返回类型ActorGateway的getJobManager,返回Actor的网关,同时兼顾了异常的情况。

上一篇 下一篇

猜你喜欢

热点阅读