storm 拆解式架构
发布时间
阅读量:
阅读量
什么是拓扑
为了实现实时计算而使用Storm工具时,则需要先搭建一个称为"拓扑结构"的有向图模型来组织数据流管理模块的功能布局. 该模型中每一个运算单元负责特定的数据处理逻辑, 各单元之间的数据传输路径则由连接它们的关系所决定.
2.Topology
TopologyBuilder是用来构建拓扑的类,在配置执行时会被用到。其底层架构基于Thrift协议,并且由于Thrift API本身较为繁琐复杂,在实际应用中可能会带来诸多不便。因此,在这种情况下,采用TopologyBuilder能够有效地降低创建和管理拓扑过程所需的复杂度
注:百度百科一下thrift。
thrift 是一个旨在支持可扩展性和跨语言服务开发的软件架构。它整合了强大的软件堆栈和代码生成引擎,在 C++, Java, Python, PHP, Ruby, Erlang, Perl, Haskell, C#, Cocoa, JavaScript, Node.js, Smalltalk 和 OCaml 等多种编程语言之间实现了无缝连接并提供了高效的解决方案。
以下是构建并提交拓扑的过程:第一步是通过关键字new初始化一个topologyBuilder对象;随后调用set_spout方法来配置_spout属性;接着使用set_bolt方法配置_bolt属性;最后调用create_topology生成storm
全部评论 (0)
还没有任何评论哟~
