说明:本人是用vm搭建的4个节点的服务,分别是node01,node02,node03,node04; node02,node03,node04上分别安装的zk, node01是hadoop的主节点,node02,node03,node04是hadoop的子节点。本人是把hbase安装在node04上为hmaster,node03为备hmater,node01,node02,node03为HregionServer
注意:每个节点上的时间要保持一致,否则在写入hbase时候会出现问题
同步时间方式,百度上还有其他方式
用ntpdate从时间服务器更新时间
如果linux系统没有ntpdate这个命令,可以输入以下代码进行安装
yum install ntp
安装完了之后,你不要做什么配置,也不需要,直接测试一下
vi /etc/ntp.conf
add below:
server 1.cn.pool.ntp.org
server 3.asia.pool.ntp.org
server 2.asia.pool.ntp.org
restart service and sync the time
[root@localhost ~]# ntpdate time.nist.gov
22 Oct 21:11:43 ntpdate[5014]: adjust time server 207.200.81.113 offset -0.018788 sec
如果显示上面的内容说明同步成功了,然后在crontab里面加上以下内容。
/10 * ntpdate time.nist.gov #域名或IP
每隔十分钟同步一次。推荐几个时间服务器。
time.nist.gov
time.nuri.net
0.asia.pool.ntp.org
1.asia.pool.ntp.org
2.asia.pool.ntp.org
3.asia.pool.ntp.org
1.上传hbase安装包并解压, 配置环境变量
修改$HBASE_HOME/conf下的hbase_env.sh里的JAVA_HOME路径以及关掉Hbase自带得zookeeper(export HBASE_MANAGES_ZK=false)
2.修改$HBASE_HOME/conf下的hbase-site.xm文件
node01
node02
node03
4.修改$HBASE_HOME/conf下的backup-masters(备用节点)里配置:
node03
完成以上步骤把hadoop下面得hdfs-site.xml拷贝到hbase/conf下把node04上配置好的hbase包分发到node01,node02,node03上注意配置环境变量。如果node01,node02,node03 hbase/conf路径下没有hadoop的hdfs-site.xml 在启动时候启动不起来。
启动前hadoop要先起来。在node04 上$HBASE_HOME/bin下执行./start-hbase.sh
这里我在hbase-site.xml中没有配置端口用的默认端口 页面默认端口16010,后台默认端口16000.高版本支持配置端口
查看帮助命令:
hbase(main):001:0> help查看表命令:
hbase(main):002:0> list查看namespace命令:(namespace可以理解为数据库)
hbase(main):003:0> list_namespace创建一个新的namespace:
hbase(main):007:0> create_namespace ‘test_ns’在test_ns下创建表:
hbase(main):009:0> create ‘test_ns:test_table’,’info’ //创建表要指定表面和列族
如果不指定namespace的话创建的表默认在default 的namespace中查看namespace的描述:
hbase(main):013:0> describe_namespace ‘test_ns’修改namespace的名称:
hbase(main):015:0> alter_namespace ‘test_ns’,{METHOD => ‘set’, ‘name’ => ‘test_ns2’}
修改前查看:
修改后查看:
删除namespace的name:
hbase(main):018:0> alter_namespace ‘test_ns’,{METHOD => ‘unset’,NAME => ‘name’}
删除表:
hbase(main):022:0> disable ‘test_ns:test_table’
hbase(main):023:0> drop ‘test_ns:test_table’
删除namespace:
hbase(main):025:0> drop_namespace ‘test_ns’ //注意如果namespace里有表,要先删表再删namespace,否则直接删namespace报错
创建分片表:
hbase(main):013:0> create ‘test_ns:teacher’,’info’,SPLITS => [‘2′,’4′,’6’]
往表里插入数据:
说明: 1 是指rowkey, name,sex,age是列名,hbase建议列族即info,不要多.put一次不能插入多条
hbase(main):029:0> put ‘test_ns:student’,’1′,’info:name’,’zhangsan’
hbase(main):030:0> put ‘test_ns:student’,’1′,’info:sex’,’male’
hbase(main):031:0> put ‘test_ns:student’,’1′,’info:age’,’22’查看表结构:
hbase(main):002:0> describe ‘test_ns:student’
添加一个列族:
hbase(main):009:0> alter ‘test_ns:student’,{NAME => ‘info1’}
删除一个列族:
hbase(main):011:0> alter ‘test_ns:student’,{‘delete’ => ‘info’}
注意:但表里只有一个列族时,不能删除,直接删除报错扫描表:
hbase(main):008:0> scan ‘test_ns:student’
通过指定版本扫描表:
hbase(main):010:0> scan ‘test_ns:student’,{RAW => true, VERSIONS => 10}
通过指定列查询数据:
hbase(main):014:0> scan ‘test_ns:student’,{COLUMNS => ‘info:name’}
分页查询:
hbase(main):016:0> scan ‘test_ns:student’,{COLUMNS => [‘info:name’],LIMIT => 2, STARTROW => ‘1’}
get查询:
hbase(main):017:0> get ‘test_ns:student’,’1′
hbase(main):018:0> get ‘test_ns:student’,’1′,’info:name’
根据时间戳查询 是一个范围,包头不包尾
hbase(main):035:0> get ‘test_ns:student’,’1′, {TIMERANGE => [1574231458967, 1574234043781]}
更新数据:
hbase(main):037:0> put ‘test_ns:student’,’1′,’info:age’,’30’
incr计数器
hbase(main):044:0> incr ‘test_ns:student’,’1′,’info:name’删除一列:
hbase(main):002:0> delete ‘test_ns:student’,’1′,’info:age’删除一行:
hbase(main):004:0> deleteall ‘test_ns:student’,’1’删除指定版本:
hbase(main):013:0> delete ‘test_ns:student’,’3′,’info:name’,TIMESTAMP => 1574232778235
判断表是否存在:
hbase(main):001:0> exists ‘test_ns:123’
统计表行数:
hbase(main):002:0> count ‘test_ns:student’
表生效和失效
hbase(main):085:0> enable ‘myns:user_info’
hbase(main):086:0> disable ‘myns:user_info’清空表数据:
hbase(main):003:0> truncate ‘test_ns:student’
=======代码示例=============
pom.xml的配置
hbase-client
import org.apache.hadoop.hbase.;
im 香港云主机port org.apache.hadoop.hbase.client.;
import org.apache.hadoop.hbase.util.Bytes;
import java.io.IOException;public class testHbaseApi {}
这篇文章主要介绍“python中的MRO原则如何使用”的相关知识,小编通过实际案例向大家展 香港云主机示操作过程,操作方法简单快捷,实用性强,希望这篇“python中的MRO原则如何使用”文章能帮助大家解决问题。1、MRO原则可以通过.__mro__属性输出相…
免责声明:本站发布的图片视频文字,以转载和分享为主,文章观点不代表本站立场,本站不承担相关法律责任;如果涉及侵权请联系邮箱:360163164@qq.com举报,并提供相关证据,经查实将立刻删除涉嫌侵权内容。