在本地安装独立的HBase和Apache Storm简单集群

我们主要使用Apache Storm进行流处理,并使用Apache HBase作为NoSQL宽列数据库。

即使Apache Cassandra是一个出色的NoSQL数据库,由于Cloudera的分布以及与Cassandra相比更加一致 (请检查CAP定理 ),我们还是更喜欢HBase。

HBase基于HDFS,但出于测试目的,可以轻松将其独立安装。 您只需要下载最新版本,解压缩文件,启动独立节点,然后启动HBase Shell即可播放。

$> tar zxvf hbase-1.1.2-bin.tar.gz
$> cd hbase-1.1.2/bin/
$> ./start-hbase.sh
$> ./hbase shell
hbase(main):001:0> create 'DummyTable', 'cf'
hbase(main):001:0> scan 'DummyTable'

在独立模式下启动HBase时,它也会自动启动本地Zookeeper节点(在默认端口2181中运行)。

$> netstat -anp|grep 2181

HBase和Storm将Zookeeper用作分布式协调器机制。 现在,由于您已经在运行本地Zookeeper节点,因此可以配置并运行本地Storm集群。

  • 下载最新的 Storm
  • 提取
  • 配置“ STORM_HOME / conf / storm.yaml”(检查以下内容)
  • 启动本地集群:
    • $> cd STORM_HOME/bin
  • 日志位于“ STORM_HOME / logs /”目录中
  • 在以下位置检查本地Storm UI: localhost:8080

新的“ storm.yaml ”配置文件的内容:

storm.zookeeper.servers:
- "localhost"nimbus.host: "localhost"supervisor.slots.ports:
- 6701
- 6702

您还可以设置参数“ worker.childopts ”来为每个Worker (处理节点)设置JVM选项。 这是本地JVM的一个简单示例,其中设置了最小/最大堆大小,垃圾回收策略,启用JXM和GC日志。

worker.childopts: "-server -Xms512m -Xmx2560m -XX:PermSize=128m -XX:MaxPermSize=512m -XX:+UseParallelOldGC -XX:ParallelGCThreads=3 -XX:+PrintGCDetails -XX:+PrintGCTimeStamps -verbose:gc -Xloggc:/tmp/gc-storm-worker-%ID%.log -Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.ssl=false -Dcom.sun.management.jmxremote.authenticate=false -Dcom.sun.management.jmxremote.port=1%ID% -XX:+PrintFlagsFinal -Djava.awt.headless=true -Djava.net.preferIPv4Stack=true"

所有Worker JVM节点均加载参数“ worker.childopts ”。 变量“%ID%”对应于分配给每个工作程序的端口(6701或6702)。 如您所见,我已经使用它为每个工作程序和不同的GC日志文件启用了不同的JMX端口。

我们使用的是使用JDK 7的Storm,但JDK 8似乎也兼容。 最新的Storm已从Logback切换到Log4j2( 在此处和此处查看完整的发行说明)。

按照上述说明,您将能够在笔记本电脑上运行HBase和Storm迷你群集,而不会出现任何问题。

翻译自: https://www.javacodegeeks.com/2015/12/local-installation-standalone-hbase-apache-storm-simple-cluster.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/355753.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

auc 和loss_深入理解AUC

在机器学习的评估指标中,AUC是一个最常见也是最常用的指标之一。AUC本身的定义是基于几何的,但是其意义十分重要,应用十分广泛。本文作者深入理解AUC,并总结于下。AUC是什么在统计和机器学习中,常常用AUC来评估二分类模…

[HTML5amp;CSS3]Transform具体解释

Transform字面上就是变形,改变的意思。在CSS3中transform主要包含以下几种:旋转rotate、扭曲skew、缩放scale和移动translate以及矩阵变形matrix。以下我们一起来看看CSS3中transform的旋转rotate、扭曲skew、缩放scale和移动translate详细怎样实现。老样…

perl转python_将行转换为perl或python中的列

我认为你可以用一张桌子做好,所以我会告诉你如何做你要求的和我认为好的。$name "";$data {};open(IN, "build.txt");foreach my $line (){if($line ~ /Re: (.*)\n/) { # get building name$name $1;$name ~ s/ /_/;$data->{$name} []; …

比亚迪定薪后多久给offer_比亚迪车主给爱车做四门隔音,没想到两年后肠子都悔青...

许多车主都有过这样的经历:总感觉爱车的静谧性不够如意,为了提升隔音效果改善驾乘质感,往往产生给爱车做一个全车隔音的冲动。只不过冲动归冲动,在着手对车子进行隔音改造工程前,一定要选择靠谱的隔音材料,…

Centos开机自己主动挂载windows中的ntfs磁盘

装了windows和centos双系统后,发如今centos中无法进入windows中的磁盘,更不要说查看磁盘里的文件了! 原来默认情况下。centos不支持Widows NTFS硬盘分区读写,要想把NTFS格式的磁盘挂载到CentOS 以下须要安装第三方软件ntfs-3g。…

人工智能方向毕业设计_毕业季|广州美术学院视觉设计学院毕业设计展

视觉艺术设计学院成立于2010年9月,由广州美术学院最传统的装潢系和新兴的数码艺术设计系联合组建而成,2018年11月,艺术与科技专业并入学院。学院现拥有视觉传达设计、数字媒体艺术设计、动画、艺术与科技4个专业。视觉文化设计工作室 视觉文化…

江西住建云实名认证怎么弄_王者荣耀无限时间怎么弄 2020年无限时间账号

腾讯游戏都是有健康系统的,王者荣耀自然也不例外,王者还是第一批出健康系统的游戏,今年健康系统同时有时间限制和充值限制,未成年玩家一天最多只能玩1.5个小时,游戏现在有传闻无限时间账号,那么无限时间怎么…

coherence安装_在Oracle Coherence中分发Spring Bean

coherence安装本文展示了如何通过使用Oracle Coherence中的EntryProcessor和可移植对象格式(POF)功能来分发Spring Bean。 Coherence通过EntryProcessor API支持无锁编程模型。 此功能通过减少网络访问并在条目上执行隐式的低级锁定来提高系统性能。 此隐…

spring 的aop操作

转载于:https://www.cnblogs.com/hwgok/p/6760663.html

excel 公式 单引号 concat_Excel两个新函数帮你快速搞定批量连接

如果将两个文本连接起来,通常第一反应用连接符号"&"。使用连接符&连接文本字符记得曾经有记者采访刘强东问奶茶妹妹漂不漂亮,他竟然回答看不出来好赖…当时真觉得这家伙身在福中不知福,饱汉不知饿汉饥。果然之后还闹出一些…

向量表示 运动抛物线_ALevel物理知识点详解:抛物线运动

考培雅思留学申请一站式服务,专为有志于申请英国G5超级精英大学以及澳洲八大、新加坡顶尖高校的中学生设计。开设有数学、进阶数学、物理、化学、生物、经济、会计等理科、商科、人文类课程, 学生可根据优势学科、兴趣爱好自由选择3-4门学习。锦秋A-Leve…

练习~虚拟线上银行

数据库操作,网络编程及多线程的综合练习~ 客户端: UI层 1 import javax.swing.*;2 import java.awt.*;3 import java.awt.event.*;4 5 public class ATMUI{6 7 //主方法8 public static void main(String [] args){9 ATMUI ui new ATMUI();…

mybatisplus 操作另一个数据库的数据_MySQL数据库的基础操作

一、基本概念数据库术语数据库(database) - 保存有组织的数据的容器(通常是一个文件或一组文件)。数据表(table) - 某种特定类型数据的结构化清单。模式(schema) - 关于数据库和表的布局及特性的信息。模式定义了数据在表中如何存储,包含存储什么样的数据&#xff0…

JEP 277“增强弃用”非常好。 但这是一个更好的选择

维护API很难。 我们正在维护非常复杂的jOOQ API。 但是就语义版本而言,我们遵循相对宽松的规则 。 当您阅读Brian Goetz和其他人关于在JDK中保持向后兼容性的评论时,我只能对他们的工作表示敬意。 显然,我们都希望最终移除Vector &#xff…

ds哈希查找—二次探测再散列_大白话之哈希表和哈希算法

哈希表概念哈希表(散列表),是基于关键码值(Key value)而直接进行访问的数据结构。也就是说,它通过把关键码值映射到表中一个位置来访问记录,以加快查找的速度。这个映射函数叫做散列函数(哈希函数&#xff…

QBC(Query By Criteria) QBE (Query By Example)

QBC 参考:(Hibernate的QBC查询) //is empty and is not emptyTestpublic void testQBC(){Session session sf.getCurrentSession();session.beginTransaction();//criterion 标准/准则/规范Criteria c session.createCriteria(Topic.class)//from Topic.add(Rest…

二叉搜索时与双向链表python_剑指Offer(二十六) 二叉搜索树和双向链表

题目描述输入一棵二叉搜索树,将该二叉搜索树转换成一个排序的双向链表。要求不能创建任何新的结点,只能调整树中结点指针的指向。思路以及解答主要是使用递归,设置一个head和end,head只在第一次设置值,后面就是将end的…

python数据分析神器_太香了!墙裂推荐6个Python数据分析神器!!

hello,大家好我是东哥! 用Python处理数据大家都不陌生了,属常规操作,但常规之下还是也有些暗藏技巧的,本篇东哥分享6个好玩高效的操作,帮助大家提高效率。 一、Pandas Profiling Pandas Profiling提供数据的…

第五天敏捷冲刺

每日任务: 1.本次会议为第三次 Meeting会议; 2.由于本次会议人员都有各自的事情,所以都通过私聊组长来,讨论接下来的任务; 3.今天的代码部分coding:https://git.coding.net/ysh0904/wl2ban.git 4.燃尽图: 5…

jsf集成spring_Spring和JSF集成:分页

jsf集成spring使用大型数据集时,通常需要以分页格式显示数据。 分页是一个有趣的问题,因为它倾向于跨越应用程序的所有层,从视图层通过应用程序服务一直到对数据库的原始调用。 在获取分页数据时,有一些非常好的解决方案。 如果您…