Storm之LocalCluster.clj
此类初始化了一些配置参数，实现了ILocalCluster接口，将拓扑结构提交到nimbus，最终通过nimbus来执行
其中最重要的看
gen-class中定义了init的函数名为”init”，继承了ILocalCluster接口
下面看init函数：
定义了3种init函数
- 无参数 设置了TOPOLOGY-ENABLE-MESSAGE-TIMEOUTS，返回ret作为state
- String 和 Long 两个参数，分别制定zookeeper的Host和Port，返回ret作为state
- java中的Map，直接返回，将map当做state
关注公众号 低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有，本站原创内容转载请注明来源。
- 上一篇
Flink on Yarn运行机制
从图中可以看出，Yarn的客户端需要获取hadoop的配置信息，连接Yarn的ResourceManager。所以要有设置有YARN_CONF_DIR或者HADOOP_CONF_DIR或者HADOOP_CONF_PATH,只要设置了其中一个环境变量，就会被读取。如果读取上述的变量失败了，那么将会选择hadoop_home的环境变量，都区成功将会尝试加载$HADOOP_HOME/etc/hadoop的配置文件。 1、当启动一个Flink Yarn会话时，客户端首先会检查本次请求的资源是否足够。资源足够将会上传包含HDFS配置信息和Flink的jar包到HDFS。 2、随后客户端会向Yarn发起请求，启动applicationMaster,随后NodeManager将会加载有配置信息和jar包，一旦完成，ApplicationMaster(AM)便启动。 3、当JobManager and AM 成功启动时,他们都属于同一个container，从而AM就能检索到JobManager的地址。此时会生成新的Flink配置信息以便TaskManagers能够连接到JobManager。同时，AM...
- 下一篇
Storm之Bolt-接口
IBolt: bolt接口类，定义了常用的几个接口，IBolt的实现类在client上被创建，然后序列化到拓扑里并被提交到集群的master上，之后nimbus会启动worker进行反序列化，调用prepare进行准备完毕之后就开始处理tuples 如果是在java里定义bolts ，建议实现IRichBolt.java接口类，IRichBolt.java同时继承了IComponent.java接口，提供了更多对拓扑进行操作的方法。 /** * 当集群中的worker初始化一个跟当前Bolt相关的task时候被调用,此方法提供和准备bolt执行时的环境. * @param stormConf 此bolt使用的storm配置,合并了本机和集群的配置,将会提供给topology * @param context task的上下文,可以获取taskId,componentId,input,output等 * @param collector 用于任意时刻提交bolt里的tuples,collector是线程安全的,应当保存在Bolt里. */ void prepare(Ma...
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
推荐阅读
最新文章
- Docker快速安装Oracle11G，搭建oracle11g学习环境
- SpringBoot2初体验，简单认识spring boot2并且搭建基础工程
- CentOS7编译安装Gcc9.2.0，解决mysql等软件编译问题
- Docker安装Oracle12C，快速搭建Oracle学习环境
- SpringBoot2全家桶，快速入门学习开发网站教程
- SpringBoot2配置默认Tomcat设置，开启更多高级功能
- CentOS关闭SELinux安全模块
- Eclipse初始化配置，告别卡顿、闪退、编译时间过长
- CentOS6,CentOS7官方镜像安装Oracle11G
- SpringBoot2整合MyBatis，连接MySql数据库做增删改查操作
微信收款码
支付宝收款码