(四)storm笔记

mkdir /var/storm

conf/storm.yaml

storm.zookeeper.servers:
- "111.222.333.444"
- "555.666.777.888"

storm.local.dir: "/mnt/storm"

nimbus.seeds: ["111.222.333.44"]

slots.ports，指定每个机器上可以启动多少个worker，一个端口号代表一个worker

supervisor.slots.ports:
- 6700
- 6701
- 6702
- 6703

(4)启动storm集群和ui界面

一个节点，storm nimbus >/dev/null 2>&1 &
三个节点，storm supervisor >/dev/null 2>&1 &
一个节点，storm ui >/dev/null 2>&1 &
三个节点，storm logviewer >/dev/null 2>&1 &

com.fastcode.eshop.storm.wordcount.WordCountTopology WordCount

原文地址：https://www.cnblogs.com/wdwyy/p/8452121.html

时间： 2024-10-13 08:41:54

(四)storm笔记的相关文章

Storm笔记整理（五）：可靠性分析、定时任务与Storm UI参数详解

[TOC] 特别说明:前面的四篇Storm笔记中,关于计算总和的例子中的spout,使用了死循环的逻辑,实际上这样做是不正确的,原因很简单,Storm提供给我们的API中,nextTuple方法就是循环执行了,这相当于是做了双层循环.因为后面在做可靠性acker案例分析时发现,加入死循环逻辑后,该nextTuple所属于的那个task根本就没有办法跳出这个nextTuple方法,也就没有办法执行后面的ack或者是fail方法,这点尤其需要注意. Storm可靠性分析基本原理 worker进程死

安卓第四天笔记-Sqlite

安卓第四天笔记-Sqlite 1.数据库的创建运行与更新 1.1.创建一个类继承SqliteOpenHelper 1.2.创建构造方法 /** * 数据库创建类 * @author 刘楠 * * 2016-2-20上午10:04:34 */ public class DbSqliteOpenHelper extends SQLiteOpenHelper { /** * * @param context 上下文 * @param name 数据库的名字如: students.db * @param

[模式识别].(希腊)西奥多里蒂斯<第四版>笔记10之__监督学习：后记

本章是监督学习的最后一部分,主要有三个目标. 首先,根据系统的分类错误概率来评估系统性能. 其次,将整个系统设计的各个阶段组合到一起. 最后,引入无标签数据,简单介绍半监督学习 1,ERROR-COUNTING方法 2,探求有限的数据集的大小 3,一个医学图像的学习案例 4,半监督学习:生成模型(generative model);基于图的方法(graph-based method); Transductive Support Vector Machines [模式识别].(希腊)西奥多里蒂

[模式识别].(希腊)西奥多里蒂斯<第四版>笔记9之__context-based classification

本章的假设前提是不同类之间存在相关性.连续的特征向量不是孤立的. 1,贝叶斯分类器 2,马尔科夫链模型 3,the viterbi algorithm 4, 信道均衡(channel equalization):任务是回复被传输通道或者噪音破坏的信息序列. 5,隐式马尔科夫模型 6,带状态持续模型(state duration model)的HMM 7,通过神经网络训练马尔科夫模型 8,马尔科夫随机场的讨论 [模式识别].(希腊)西奥多里蒂斯<第四版>笔记9之__context-based c

[模式识别].(希腊)西奥多里蒂斯<第四版>笔记10之__聚类：基本概念

一,引言之前几个章节讨论的都是监督聚类,从本章开始讨论非监督聚类,即训练模式不带标签的情形. 聚类的步骤: 1,特征选择.选取最能够表示我们目标物体信息的特征. 2,相似性度量.给出两个特征量相似点或者不想似的地方. 3,聚类标准.聚类标准.可能由损耗函数(cost function)或者其他形式表达. 4,聚类算法.根据相似性度量和聚类标准,阐明数据的结构. 5,结果验证. 6,解释结果. 不同的特征.相似性度量.聚类标准和聚类算法会导致完全不同的结果. 主观性会一直伴随我们.(Subjec

[模式识别].(希腊)西奥多里蒂斯<第四版>笔记4之__非线性分类器

1,Exclusive OR(XOR)Booleanfunction问题布尔量AND和OR是线性可分的 2,两层感知器对Figure4.1中A类和B类,首先能想到的是画两条直线.如图Figure4.4. ① 两层感知器的分类能力 3,三层感知器 4,基于训练集精确分类的算法 5,反向传播算法 6,反向传播主题的变种 7,成本函数的选择(THE COST FUNCTION CHOICE) 8, 网络尺寸的选择 9,权重共享网络 10,广义线性分类器 11,线性二分法的维度空间容量

辛星笔记之MySQL的InnoDB部分的四本笔记

第一本就是InnoDB的事务实现机制,在csdn上的下载地址为:点我下载 ,这里简要介绍下,它是通过redo和undo来控制的,而且每一秒钟都会把日志缓冲刷新到重做日志文件,因此对于再大的事务提交也非常快捷.对于undo日志,它则是用于事务的回滚,它在共享表空间中有自己的undo段.对于事务的隔离级别,是通过锁来实现的,因此这就需要理解InnoDB的锁机制.其中还有对分布式事务即xa的部分介绍. 第二本是InnoDB的锁机制,在csdn上的下载地址为:点我下载 ,它主要是介绍了InnoDB的锁机

Storm笔记整理（四）：Storm核心概念与验证——并行度与流式分组

[TOC] Storm核心概念之并行度 Work 1个worker进程执行的是1个topology的子集(注:不会出现1个worker为多个topology服务).1个worker进程会启动1个或多个executor线程来执行1个topology的(spout或bolt).因此,1个运行中的topology就是由集群中多台(可能是一台)物理机上的一个或者多个worker进程组成的. Executor executor是worker进程启动的一个单独线程. 每个executor只会运行1个topo

IOS阶段学习第四天笔记（循环）

IOS学习(C语言)知识点整理笔记一.分支结构 1.分支结构分为单分支即:if( ){ } ;多分支即:if( ){ }else{ } 两种 2.单分支 if表达式成立则执行{ }里的语句:双分支 if表达式不成立则执行else{ }里面的语句 3.字符串的输出系统会从数组地址一直打印到字符 ‘\0’为止,如果没有正确初始化,可能会打印出数组外的信息 4.如果分支结构里面只有一条执行语句可省略外面的大括号{} . 二.开关语句 1.语句结构 :switch (参数) case