topology 开发完成后,需要提交给storm集群,才能够运行。
提交storm的常用命令
1、把 topology 项目打成 jar 包后,上传到 Storm 集群后,可以使用下面命令提交 topology
bin/storm jar jarName.jar [TopologyMai……继续阅读 »
jiajun
2年前 (2018-11-20) 550浏览 0评论
0个赞
本文介绍如何创建一个简单的 Storm 项目,只有一个 spout 和一个 bolt,如下图所示:
1、新建 maven 项目,并引进依赖。
<dependency>
<groupId>org.apache.storm</groupId……继续阅读 »
jiajun
2年前 (2018-11-20) 573浏览 0评论
0个赞
tuple
Storm 应用程序能够直接处理的基本数据单元称为 tuple(元组)。每个 tuple 由预定义的 field(字段 )列表组成。每个 field 的值类型可以是 byte、char、integer、long、float、double、Boolean 或 byte 数组。此外,Storm 提供了……继续阅读 »
jiajun
2年前 (2018-11-20) 730浏览 0评论
0个赞
storm集群采用主从构架、主节点跟从节点之间的协调工作都是通过 ZooKeeper 集群来完成的。下面是storm集群的构架图:
Nimbus
Nimbus 是storm集群的主节点。在 nimbus 节点上存在一个叫 nimbus 的守护进程。nimbus 节点负责在不同的 work……继续阅读 »
jiajun
2年前 (2018-09-24) 533浏览 0评论
0个赞
环境
host
s100、s101、s102
对应 ip:
192.168.163.100
192.168.163.101
192.168.163.102
操作系统:
centos7
步骤
1、关闭防火墙
systemctl stop firewalld
……继续阅读 »
jiajun
3年前 (2018-09-01) 646浏览 0评论
0个赞