flink作业上下文监听器——JobListeningContext保存监视正在运行的作业并接收其结果所需的状态。该类下包含有以下几个属性：作业id、应答时间、flink Configuration配置信息、以及类加载器ClassLoader。还有最为重要的两个属性：ActorSystem以及jobClientActor。根据大神的博客知道flink中的ActorSystem用于进行消息的传递和通信。该类中含有一个公有的方法，方法名同类名相同，即为该类的构造函数。
图1该类中的后半部分代码均为get属性值得方法，以及名为getClassLoader的方法，。用于反序列化作业执行结果中所需的类加载器，决定返回结果还是抛出异常。最后是一个方法是getJobManager()，也是防止出现异常，返回类型ActorGateway的getJobManager，返回Actor的网关，同时兼顾了异常的情况。
flink作业上下文监听器——JobListeningContext保存监视正在运行的作业并接收其结果所需的状态。...
Flink HA Flink HA 的HighAvailabilityMode类中定义了是那种高可用性模式枚举: ...
在flink的function类中传递参数，对于flink datastream和dataset是不同的，对于da...
Flink重要配置： Flink重要的配置类 配置类说明备注ResourceManagerOptions.java...
1.Flink的TypeInformation类 TypeInformation是flink中所有类型的基类，其作...
Flink学习笔记：时间与窗口 1. 时间 在flink中定义了三类时间： 事件时间（Event Time）：即事...
1. Flink 时间语义 Flink定义了三类时间 处理时间（Process Time）数据进入Flink被处理...
flink中的状态分为两类：Keyed State、Operator State；Keyed State是只能定义...
根据Flink文档Flink 的 TypeInformation 类介绍: POJOs 是特别有趣的，因为他们支持...
Flink中的Time类型 Flink中的Windows编程 Flink的watermarks Event Tim...
本文标题：flink中的JobListeningContext类
本文链接：https://www.haomeiwen.com/subject/vpqjaftx.html
网友评论