hbase连接设置密码(hbase教程菜鸟教程) -k8体育

hbase采用java实现,其中 java api 是原生支持的,其它编程语言接口需要通过 thrift 协议支持。在hbase 官方代码包里含有java实现的原生访问客户端,相关的类在 org.apache.hadoop.hbase.client 包中,都是与 hbase 数据存储管理相关的 api。

基本操作有:hbase 的配置、hbase 表的管理、列族的管理、列的管理、数据操作等。

官方的jar包在hbase 安装目录下的 lib 子目录。但是一般还是使用maven管理jar依赖。主要用到hbase-client-x.x.x.jar和hbase-common-x.x.x.jar。

maven管理依赖,在项目的pom.xml加:


    org.apache.hbase
    hbase-client
    2.4.1


    org.apache.hbase
    hbase-common
    2.4.1

导入的基本类有:

import org.apache.hadoop.conf.configuration;
import org.apache.hadoop.hbase.*;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.bytes;

管理 hbase,则用 admin 接口来创建、删除、更改表。数据的crud,则使用 table 接口等。主要是admin 和 table 接 口以及 hbaseconfiguration、htabledescriptor、hclounmdescriptor、put、get、result、scan 这些类。

  • admin、管理hbase数据库的表信息的接口。
  • hbaseconfiguration、hbase的配置类。
  • htabledescriptor、表的描述类,包含了表的名字及其对应表的列族。
  • hclounmdescriptor、列族描述类,维护着关于列族的信息,例如版本号,压缩设置等。
  • htable、表的管理类,和hbase表直接通信。
  • put、数据新增修改管理类,对单个行执行添加操作。
  • get、数据获取管理类,对单个行执行查询操作。
  • result、结果类,存储get或者scan操作后获取表的单行值。
  • scan、限定查找类,对多个行执行查询操作。
  • resultscanner、获取scan值的接口类。
  • 建立连接,在分布式环境下,客户端访问 hbase 需要通过 zookeeper 的地址和端口来获取当前活跃的 master 和所需的 regionserver 地址。在hbase3.0 中,可以直接使用master地址。
configuration cf = hbaseconfiguration.create();
//默认也是2181
// configuration.set(\"hbase.zookeeper.property.clientport\", \"2181\");
cf.set(\"hbase.zookeeper.quorum\", \"10.0.3.71\");
// v3.0可只配置master地址。
// cf.set(\"hbase.master\", \"10.0.3.71:16000\");
connection conn = connectionfactory.createconnection(cf);
//使用完后,需要关闭连接
void close();
  • 表操作,都是使用 admin 接口,必须调用 connection.getadmin() 方法返回一个子对象。
string tablename = \"tablename\";
tablename tablename = tablename.valueof(tablename);
admin admin = conn.getadmin();
//admin常用的接口如下:
//表是否存在
boolean tableexists(tablename tablename);
//列出所有表
list listtabledescriptors();
//删除表,先禁用表,再删除
void disabletable(tablename tablename);
void deletetable(tablename tablename);
//启用已禁用的表
void enabletable(tablename tablename);
//给表加字段
void addcolumnfamily(tablename tablename, columnfamilydescriptor columnfamily);
//创建表,需要指定列族
string columnname = \"cf\";
list families = new arraylist<>();
columnfamilydescriptor cfdesc = columnfamilydescriptorbuilder.newbuilder(columnname.getbytes()).build();
families.add(cfdesc);
tabledescriptor tabdesc = tabledescriptorbuilder.newbuilder(tablename).setcolumnfamilies(families).build();
admin.createtable(tabdesc);
admin.getconnection().close();
  • 数据访问,通过table对象连接到hbase进行操作。新增数据如下:
//需要先有table与tablename实例
table table = conn.gettable(tablename);
//一行,参数是rowkey
put put = new put (\"rowkeyname\".getbytes());
//加字段值:参数分别是列族,列,值
put.add(\"cfname\".getbytes(),\"colname\".getbytes(),\"value001\".getbytes());
table.put(put);

获取单行数据如下:

get get = new get(\"rowkeyname\".getbytes());
result result = table.get(get);
//从结果中拿到单元值
for (cell cell : result.rawcells()) {
    //列族名 cell.getfamilyarray()
    //列名 cell.getqualifierarray()
    //值 cell.getvaluearray()
    s
}

限定查找,可指定版本号、起始行号、终止行号、列族、列限定符、返回值的数量的上限等:

scan scan = new scan();
//可以指定scan参数:addcolumn、settimerange、setbatch
resultscanner resutscanner = table.getscanner(scan);
//拿到结果集
for(result result: resutscanner){
    //对结果进行列值提取 result.rawcells()
}
  • nonode for /hbase/master master没有正常启动,将hbase的master节点重启一下。
  • master is initializing master在zookeeper中的数据不正常,删除后,重启一下hbase。hdfs中的文件也要删除一下。
(0)
仰望辉煌。  的头像仰望辉煌。  

相关推荐

  • 有些游戏需要特定的系统版本 更新了就没法玩了有些小伙伴们是非常的闹心,w软现在g更新也是不考虑大家的感受 直接强制更新,现在win10的自动更新可谓是非常顽固,重启电脑才发现系统正…

  • 全文字数1994,阅读需要6分钟导读:招商人的六个思维层次,你在哪一层?关于人的思维层次,爱因斯坦曾说过:「我们不能用制造问题时的同一水平思维来解决问题」。通俗点说,要解决问题,需要把思维再提升一个高度,否则问题很难得到解决。在招商工作中,

    2023年4月2日 创业分享
  • 产品市场营销推广策略 3个营销技巧及方案总结 3个方法教你如何做好市场营销推广 市场营销推广的基本逻辑就是做好3件事: 一、营销以市场和顾客为载体 有效经营中的营销有两个独特的功能…

  • 一、形状误差的检测 1.直线度误差的检测: 2.平面度误差的检测: 3.圆度误差的检测 检测外圆表面的圆度误差时,可用千分尺测出同一正截面的最大直径差,此差值的一半即为该截面的圆度…

  • 不管是否情愿,生活总在催促我们迈步向前。人们整装、启程、跋涉、落脚,停在哪里,哪里就会燃气灶火。 陈晓卿也没逃过被迫推着前进的宿命。作为《舌尖上的中国 1、2》的总导演,眼看着互联…

    2022年1月18日 创业分享
  • 雨总:跟大家简单分析一下现在有哪些比较好的行业,希望对有择业需求的销售有帮助: 1、宠物行业 宠物行业发展迅速,我们有716学员在一家宠物行业公司做线上销售总监,年薪40万打底。 …

    创业分享 2022年3月26日
  • 在建筑、景观、室内等设计领域,需求方和供给方信息不对称的问题一直存在。花更低的时间成本,精准匹配到合适的设计团队一直是需求方的痛点。一旦项目返工,将带来无法估算的物质成本和时间损失…

  • 比来 正在网上看到许多 人皆正在“坚皮五花肉”,看患上让人异常 的食欲年夜 删,这么,那面昨天也分享那叙中层金黄酥坚,面层瘦而没有腻的“坚皮五花肉”给年夜 野。爱吃辣的同伙 们,否…

  • 北京时间7月2日下午,荣耀召开新品发布会正式发布了荣耀x10 max和荣耀30青春版两款5g新品,让荣耀的5g手机阵营进一步壮大。这其中,荣耀x10 max作为荣耀的首款5g大屏手…

  • 今天,几乎每个企业都在拥抱大数据,随着流量红利消失,用户的需求逐渐变得复杂多元,让大部分企业困于无法真正了解自己的用户,越来越多的企业开始从过去粗放的用户运营转向基于大数据的全渠道…

    2022年3月26日 创业分享
  • 创业有成功也有失败,成功的比如被大家都所熟知的大名鼎鼎的马云,雷军等互联网创业者。但是今天我们文章的主人公并不是他,而是万兴科技董事长吴太兵。 他坚持出海创业 15 年。 他将消费…

  • 在感情生活中,两个人是否能融洽相处,三观相符很重要,如果三观不合,在相处过程中经常会出现争吵与矛盾,那么怎么判断两个人三观合不合呢?在日常生活中,可以从以下几方面表现出来。 一、不…

  • 天猫商城 天猫是b2c(企业对消费者)领域的老大,是纯开放平台,利润来自于流量、广告和技术服务费。 优势:①规模大②商品种类多③流量大④纯平台成本低⑤知名度高、 劣势:①对商品控制…

    2021年11月30日 创业分享
  • seer 使用过mac 的读者都知道,使用空格键就可以预览文件,但是windows 笔记本就需要右键打开,真的是望尘莫及,而seer 就是这样一个软件,可以让你在普通笔记本也可以拥…

  • 图层的关闭/打开,冷冻/解冻,锁定/解锁可以帮助绘图人员自如的应用复杂的图层中。以小编的一部成品为例,打开图层,灯泡是图层的关闭/打开,太阳是冷冻/解冻,锁是锁定/解锁 一、先介绍…

发表回复

登录后才能评论
网站地图