hbase java api最新版本_HBase基本命令与新版本Java API

简介

有关HBase的安装可以参考hbase安装

我们可以通过hbase shell和hbase数据库进行交互，也可以通过Java-api和hbase数据库交互，这里我们使用的是hbase-client。

主要是介绍2.0重大重构之后的api的基本使用。

9f18bdf12c27dd80b8e85d2718a84340.png

命名空间

#列出所有命名空间

list_namespace

#新建命名空间

create_namespace 'namespaceName'

#删除命名空间

drop_namespace 'namespaceName'

#修改命名空间

表操作

create:创建表

exists:检查表是否存在

list:查看所有表

alter：修改表

delete：删除列

disable:禁用表

is_enabled：查看表是否禁用

desc\describe:查看表结构

drop:删除表

put:插入数据

count:统计表有多少行

get:获取数据

scan:扫描表或者列

#列出所有表

list

#列出指定命名空间下的所有表

list_namespace_tables 'namespaceName'

#新建一个以命名空间namespaceName的表tableName，列族为cf1。

create 'namespaceName:tableName', 'cf1'

create 'tablename','columnFamily1','columnFamily2'

create 'tablename',{NAME => 'columnFamily1',VERSIONS => 1, TTL => 214783647, BLOCKCACHE => false,IN_MEMORY=>false},{NAME=>'columnFamily2',VERSIONS=>1,TTL=>259200,BLOCKCACHE=>false,IN_MEMORY=>false}

disable 'tableName'

#删除表

drop 'tableName'

#查看表内容，查看前5行数据

scan 'namespaceName:tableName', {LIMIT=>5}

#插入 put tableName rowkey,"columnFamily:column","value"

put 'tableName', 'rowkey', 'columnFamilyName:columnName', 'value'

#查看 get rowKey

get 'tableName', 'rowkey'

删除表中的列簇，先disable表，修改后enable表，严格区分大小写

scan

查询user表中的所有信息

scan 'user'

查询user表中列族为info的信息

scan 'user', {COLUMNS => 'info'}

scan 'user', {COLUMNS => 'info', RAW => true, VERSIONS => 5}

查询user表中列族为info和data的信息

scan 'user', {COLUMNS => ['info', 'data']}

scan 'user', {COLUMNS => ['info:name', 'data:pic']}

查询user表中列族为info、列标示符为name的信息

scan 'user', {COLUMNS => 'info:name'}

查询user表中列族为info、列标示符为name的信息,并且版本最新的5个

scan 'user', {COLUMNS => 'info:name', VERSIONS => 5}

查询user表中列族为info和data且列标示符中含有a字符的信息

scan 'user', {COLUMNS => ['info', 'data'], FILTER => "(QualifierFilter(=,'substring:a'))"}

查询user表中row key为rk0001，cell的值为中国

scan 'user', 'rk0001', {FILTER => "ValueFilter(=,'binary:中国')"}

查询user表中row key为rk0001，列标示符中含有a的信息

scan 'user', 'rk0001', {FILTER => "(QualifierFilter(=,'substring:a'))"}

查询user表中row key以rk字符开头的

scan 'user',{FILTER=>"PrefixFilter('rk')"}

查询user表中列族为info，rk范围是[rk0001, rk0003)的数据

scan 'user', {COLUMNS => 'info', STARTROW => 'rk0001', ENDROW => 'rk0003'}

查询user表中指定范围的数据

scan 'user', {TIMERANGE => [1392368783980, 1392380169184]}

get命令也可以使用如上所示的scan命令方式

基本命令

help:查看命令帮助

status:查看hbase状态

version:查看hbase版本

快照

修改表名HBase没有rename命令，可以通过快照功能修改表名

//为表创建快照，这时还没有复制数据

clone_snapshot 'tableSnapshot', 'newTableName'

//根据某个快照而创建新表，此时复制数据

snapshot 'tableName', 'tableSnapshot'

//删除快照

delete_snapshot 'tableSnapshot'

Java API

org.apache.hbase

hbase-client

2.2.0

import org.apache.hadoop.conf.Configuration;

import org.apache.hadoop.hbase.Cell;

import org.apache.hadoop.hbase.HBaseConfiguration;

import org.apache.hadoop.hbase.NamespaceDescriptor;

import org.apache.hadoop.hbase.TableName;

import org.apache.hadoop.hbase.client.*;

import org.apache.hadoop.hbase.util.Bytes;

import org.junit.Before;

import org.junit.Test;

import java.io.IOException;

import java.util.LinkedList;

import java.util.List;

import java.util.Random;

public class HBaseTest {

private static final String ZOOKEEPER_QUORUM = "127.0.0.1:2181";

public static final String TABLE_NAME = "test_tb";

private Connection connection;

private Configuration configuration;

@Before

public void setUp() throws IOException {

configuration = HBaseConfiguration.create();

configuration.set("hbase.zookeeper.quorum", ZOOKEEPER_QUORUM);

connection = ConnectionFactory.createConnection(configuration);

}

@Test

public void createTable() throws Exception {

Admin admin = connection.getAdmin();

TableName tableName = TableName.valueOf(TABLE_NAME);

TableDescriptorBuilder tableDescriptorBuilder = TableDescriptorBuilder.newBuilder(tableName);

ColumnFamilyDescriptor baseInfo = ColumnFamilyDescriptorBuilder.of("base_info");

ColumnFamilyDescriptor extInfo = ColumnFamilyDescriptorBuilder.of("ext_info");

tableDescriptorBuilder.setColumnFamily(baseInfo);

tableDescriptorBuilder.setColumnFamily(extInfo);

TableDescriptor tableDescriptor = tableDescriptorBuilder.build();

admin.createTable(tableDescriptor);

}

@Test

public void dealTable() throws IOException {

Admin admin = connection.getAdmin();

String tableNameString = "test_user";

TableName tableName = TableName.valueOf(tableNameString);

if(admin.tableExists(tableName)){

admin.disableTable(tableName);

admin.deleteTable(tableName);

}

}

@Test

public void descTable() throws IOException {

TableName tableName = TableName.valueOf(TABLE_NAME);

Table table = connection.getTable(tableName);

TableDescriptor tableDescriptor = table.getDescriptor();

ColumnFamilyDescriptor[] columnFamilies = tableDescriptor.getColumnFamilies();

for(ColumnFamilyDescriptor cfd : columnFamilies){

System.out.println(Bytes.toString(cfd.getName()));

}

}

@Test

public void put() throws Exception {

TableName tableName = TableName.valueOf(TABLE_NAME);

Table table = connection.getTable(tableName);

Put put=new Put(Bytes.toBytes("user_info_1"));

// put.addColumn(Bytes.toBytes(familyName), Bytes.toBytes(columnName), Bytes.toBytes(value));

put.addColumn(Bytes.toBytes("base_info"), Bytes.toBytes("name"), Bytes.toBytes("tim"));

put.addColumn(Bytes.toBytes("base_info"), Bytes.toBytes("tel"), Bytes.toBytes("123"));

table.put(put);

}

@Test

public void puts() throws Exception {

TableName tableName = TableName.valueOf(TABLE_NAME);

Table table = connection.getTable(tableName);

LinkedList puts = new LinkedList<>();

puts.add(getPut("user_info_2"));

puts.add(getPut("user_info_3"));

puts.add(getPut("user_info_4"));

table.put(puts);

}

private static Put getPut(String rowKey){

Put put=new Put(Bytes.toBytes(rowKey));

Random random = new Random();

String name = String.valueOf(random.nextInt(1000000));

put.addColumn(Bytes.toBytes("base_info"), Bytes.toBytes("name"), Bytes.toBytes(name));

put.addColumn(Bytes.toBytes("base_info"), Bytes.toBytes("tel"), Bytes.toBytes(name));

return put;

}

@Test

public void get() throws Exception {

TableName tableName = TableName.valueOf(TABLE_NAME);

Table table = connection.getTable(tableName);

Get get =new Get(Bytes.toBytes("user_info_1"));

get.addColumn(Bytes.toBytes("base_info"), Bytes.toBytes("name"));

Result result=table.get(get);

List cells = result.listCells();

for(Cell cell: cells){

System.out.println(Bytes.toString(cell.getFamilyArray()));

System.out.println(Bytes.toString(cell.getQualifierArray()));

System.out.println(Bytes.toString(cell.getValueArray()));

System.out.println(cell.getTimestamp());

}

}

@Test

public void gets() throws IOException {

TableName tableName = TableName.valueOf(TABLE_NAME);

Table table = connection.getTable(tableName);

LinkedList gets = new LinkedList<>();

gets.add(getGet("user_info_1"));

gets.add(getGet("user_info_2"));

gets.add(getGet("user_info_3"));

gets.add(getGet("user_info_4"));

Result[] results = table.get(gets);

for(Result result : results){

System.out.println(new String(result.getRow()));

System.out.println(new String(result.getValue(Bytes.toBytes("base_info"), Bytes.toBytes("name"))));

System.out.println(new String(result.getValue(Bytes.toBytes("base_info"), Bytes.toBytes("tel"))));

}

}

private static Get getGet(String rowKey){

Get get =new Get(Bytes.toBytes(rowKey));

get.addColumn(Bytes.toBytes("base_info"), Bytes.toBytes("name"));

get.addColumn(Bytes.toBytes("base_info"), Bytes.toBytes("tel"));

return get;

}

@Test

public void scan() throws IOException {

TableName tableName = TableName.valueOf(TABLE_NAME);

Table table = connection.getTable(tableName);

Scan s = new Scan();

ResultScanner resultScanner = table.getScanner(s);

for(Result result : resultScanner){

byte[] row = result.getRow();

System.out.println(new String(row));

System.out.println(new String(result.getValue(Bytes.toBytes("base_info"), Bytes.toBytes("name"))));

}

}

@Test

public void deleteRowKey() throws Exception {

TableName tableName = TableName.valueOf(TABLE_NAME);

Table table = connection.getTable(tableName);

Delete de =new Delete(Bytes.toBytes("rowKey"));

table.delete(de);

}

@Test

public void deleteColumn() throws Exception {

TableName tableName = TableName.valueOf(TABLE_NAME);

Table table = connection.getTable(tableName);

Delete de =new Delete(Bytes.toBytes("rowKey"));

de.addColumn(Bytes.toBytes(""), Bytes.toBytes(""));

table.delete(de);

}

@Test

public void disableTable() throws Exception {

TableName tableName = TableName.valueOf(TABLE_NAME);

Admin admin = connection.getAdmin();

admin.disableTable(tableName);

}

@Test

public void listNamespace() throws Exception {

Admin admin = connection.getAdmin();

NamespaceDescriptor[] namespaceDescriptors = admin.listNamespaceDescriptors();

for(NamespaceDescriptor namespaceDescriptor : namespaceDescriptors){

System.out.println(namespaceDescriptor.getName());

}

}

@Test

public void listTables() throws IOException {

Admin admin = connection.getAdmin();

List tableDescriptors = admin.listTableDescriptors();

for(TableDescriptor tableDescriptor : tableDescriptors){

System.out.println(tableDescriptor.getTableName().getNameAsString());

}

}

}

重点就是构建连接：

Configuration configuration = HBaseConfiguration.create();

configuration.set("hbase.zookeeper.quorum", "127.0.0.1:2181");

Connection connection = ConnectionFactory.createConnection(configuration);

相关的操作基本和Admin有关，通过Connection获取Admin：

Admin admin = connection.getAdmin();

不再使用字符串表明，而是使用TableName抽象：

TableName tableName = TableName.valueOf("tableName");

表描述构建：

TableDescriptorBuilder tableDescriptorBuilder = TableDescriptorBuilder.newBuilder(tableName);

列簇构建：

ColumnFamilyDescriptor baseInfo = ColumnFamilyDescriptorBuilder.of("base_info");

下面的createTable基本把表相关的抽象都使用到了：

@Test

public void createTable() throws Exception {

Admin admin = connection.getAdmin();

TableName tableName = TableName.valueOf(TABLE_NAME);

TableDescriptorBuilder tableDescriptorBuilder = TableDescriptorBuilder.newBuilder(tableName);

ColumnFamilyDescriptor baseInfo = ColumnFamilyDescriptorBuilder.of("base_info");

ColumnFamilyDescriptor extInfo = ColumnFamilyDescriptorBuilder.of("ext_info");

tableDescriptorBuilder.setColumnFamily(baseInfo);

tableDescriptorBuilder.setColumnFamily(extInfo);

TableDescriptor tableDescriptor = tableDescriptorBuilder.build();

admin.createTable(tableDescriptor);

}

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

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

相关文章

leetcode 贪心_贪心算法：给我最好的，现在就要！

leetcode 贪心_贪心算法：给我最好的，现在就要！

每次做选择的时候都做出当下最好的选择&#xff0c;而不考虑将来的后果。并且期望最终得到的结果是全局最优的。 ——贪心算法 - Greedy Algorithm什么时候该使用贪心算法针对一组数据&#xff0c;定义了限制值。现在需要我们从中选出几个数据&#xff0c;在满足限制值的情况下…
阅读更多...
java导致native非法指令,Java代码引起的NATIVE野指针问题（上）

java导致native非法指令,Java代码引起的NATIVE野指针问题（上）

朴英敏&#xff0c;小米MIUI部门。从事嵌入式开发和调试工作8年多&#xff0c;擅长逆向分析方法&#xff0c;主要负责解决安卓系统稳定性问题。上周音乐组同事反馈了一个必现Native Crash问题&#xff0c;tombstone如下&#xff1a; pid: 5028, tid: 5028, name: com.miui.play…
阅读更多...
axure怎么做5秒倒计时_罗胖60秒：怎么做一个课程？

axure怎么做5秒倒计时_罗胖60秒：怎么做一个课程？

今天是罗胖陪伴你的第 2714 天1. 我们在研发课程的时候&#xff0c;有一个很关键的方法&#xff0c;我们内部称之为叫“不是而是”大法。2. 什么意思呢&#xff1f;就是如果你只告诉别人它是什么&#xff0c;那等于啥都没说。比如&#xff0c;我告诉你要经营好一家小店&#xf…
阅读更多...
php7 变量,PHP7变量结构分析

php7 变量,PHP7变量结构分析

PHP7相对于PHP5提升了将近一倍的性能&#xff0c;下面我将针对PHP7与PHP5的变量结构实现进行对比&#xff0c;分析为什么PHP7性能提升。当然变量结构修改只是PHP7性能提升中的一部分原因&#xff0c;还有很多原因比如HashTable结构变更、减少内存分配次数、多使用栈内存等等&am…
阅读更多...
点在不规则图形内算法python_目标检测算法中规则矩形和不规则四边形IOU的Python实现...

点在不规则图形内算法python_目标检测算法中规则矩形和不规则四边形IOU的Python实现...

交并比(Intersection-over-Union&#xff0c;IoU)&#xff0c;目标检测中使用的一个概念&#xff0c;我们在进行目标检测算法测试时&#xff0c;重要的指标&#xff0c;是产生的预测框(candidate bound)与标记框(ground truth bound)的交叠率&#xff0c;即它们的交集与并集的比…
阅读更多...
树莓派跑php,在树莓派4上部署nginx+php

树莓派跑php,在树莓派4上部署nginx+php

本试验是基于树莓派的 buster 版本。一、安装 nginxapt install nginx -y完成安装之后&#xff0c;可以使用 dpkg -l | grep nginx 找到相关的安装包&#xff1a;通过分析 /var/lib/dpkg/status 可以得到 nginx 安装包的依赖关系&#xff1a;nginx --> nginx-full --> li…
阅读更多...
只有python可以爬虫吗_无所不能的Python之爬虫那点事儿

只有python可以爬虫吗_无所不能的Python之爬虫那点事儿

今天给大家介绍一个有趣的新技术——爬虫。首先来讲一下啥是爬虫。爬虫也叫网络爬虫&#xff0c;是一种按照一定的规则&#xff0c;自动地抓取万维网信息的程序或者脚本。通俗的来讲&#xff0c;爬虫就是一段程序&#xff0c;它来根据你的设定自己去互联网上浏览网页并把这些信…
阅读更多...
java排队系统模型,MMC排队系统模型

java排队系统模型,MMC排队系统模型

MMC排队系统模型及应用M/M/C排队模型及其应用摘要&#xff1a;将随机服务系统中M/M/C排队模型应用到理发服务行业中。通过对某理发店进行调查&#xff0c;以10min为一个调查单位调查顾客到达数&#xff0c;统计了72个调查单位的数据&#xff0c;又随机调查了113名顾客服务时间&…
阅读更多...
php 如何生成微信小程序,微信小程序一键生成平台系统/一键生成小程序开源小程序PHP|ThinkPHP平台源码下载...

php 如何生成微信小程序,微信小程序一键生成平台系统/一键生成小程序开源小程序PHP|ThinkPHP平台源码下载...

源码名称&#xff1a;微信小程序一键生成平台系统/一键生成小程序开源小程序PHP|ThinkPHP平台源码下载购买须知&#xff1a;(请仔细阅读了解)【1】源码一律经测试无误。【2】不提供任何修改和编辑服务&#xff0c;不包安装调试&#xff0c;假如你什么都不懂的请不要拍。【3】假…
阅读更多...
python excel格式刷_Excel格式刷怎么用？没你想的那么简单，你知道几种用法？

python excel格式刷_Excel格式刷怎么用？没你想的那么简单，你知道几种用法？

【温馨提示】亲爱的朋友&#xff0c;阅读之前请您点击【关注】&#xff0c;您的支持将是我最大的动力&#xff01;Excel使用过程中&#xff0c;格式刷相信小伙伴们都知道&#xff0c;平常也没少用。Excel中格式刷可以帮助我们快速的复制单元格的格式&#xff0c;而不用再重新设…
阅读更多...
php接受post接受不到数据,PHP $_POST接受不到数据，但$_GET可以接受数据

php接受post接受不到数据,PHP $_POST接受不到数据，但$_GET可以接受数据

"HTML ajax端 $.ajax({ url:/login.php, data:{name:name, pwd:pwd}, type:POST, dataType:json, success:function(data){ console.dir(data) if(data.status 1) alert(data.mes) }else{ alert(data.mes) } } })php端&#xff1a;$sql "SELECT * FROM user WHERE …
阅读更多...
python安装多个版本_Mac安装多个python版本

python安装多个版本_Mac安装多个python版本

Mac安装多个python版本步骤如下&#xff1a;1、安装pyenv$sudo brew install pyenv然后在 .bash_profile 文件中添加命令&#xff1a;vi .bash_profile添加&#xff1a;eval "$(pyenv init -)"最后&#xff0c;更新一下环境变量命令&#xff1a;source .bash_profile…
阅读更多...
java .item,javabb-javaitem-cloud

java .item,javabb-javaitem-cloud

JavaItem-Cloud项目介绍JavaItem-Cloud是一个新开发的微服务架构平台&#xff0c;基于最新流行的技术SpringBoot、SpringCloud & SpringCloud Alibaba、Vue、Vuex、ElementUI。系统特性后端使用当前流行技术&#xff0c;SpringBoot、SpringCloud、SpringCloud Alibaba、Myb…
阅读更多...
软件使用手册模板_我的印象笔记使用手册（精简说明）

软件使用手册模板_我的印象笔记使用手册（精简说明）

在之前的一文中&#xff0c;我已经详细写过我的印象笔记使用的方法了&#xff0c;这次呢&#xff0c;再做一个更新的使用情况和更清楚明了和精简的说明。不居竹&#xff1a;我的印象笔记使用手册​zhuanlan.zhihu.com文章目录&#xff1a;1、知识管理收集知识整理知识输出知识2…
阅读更多...
java 响应事件,用java响应颜色事件

java 响应事件,用java响应颜色事件

我正在构建一个java应用程序来解决难题 . 我编码的方式基本上是程序将采取屏幕截图&#xff0c;在屏幕截图中找到一个像素&#xff0c;并通过机器人功能将鼠标移动到桌面上的那个位置 . 我理解屏幕截图背后的理论&#xff0c;将其存储在一个数组中&#xff0c;探索数组直到一个…
阅读更多...
怎样保存python源程序_五分钟教会你如何编写、保存与运行 Python 程序

怎样保存python源程序_五分钟教会你如何编写、保存与运行 Python 程序

第一步接下来我们将看见如何在 Python 中运行一个传统的“Hello World”程序。Python教程本章将会教你如何编写、保存与运行 Python 程序。通过 Python 来运行的你的程序有两种方法——使用交互式解释器提示符或直接运行一个源代码文件。我们将了解如何使用他们二者的功能。使用…
阅读更多...
matlab实验8数据分析与多项式计算,hashidamatlab实验八数据处理与多项式计算.doc

matlab实验8数据分析与多项式计算,hashidamatlab实验八数据处理与多项式计算.doc

实验八电子二班张秀云 一、实验目的〔据处理与多项式计算1、掌握数据统计和分析的方法2、掌握数值插值与曲线拟合的方法及其应用3、掌握多项式的常用运算二、实验内容1、利用MATLAB提供的rand函数生成30000个符合均匀分布的随机 数&#xff0c;然后检验随机数的性质&#xff1a…
阅读更多...
微信群定时发消息 python_Python实现每天定时发微信问候语

微信群定时发消息 python_Python实现每天定时发微信问候语

IT学习乐园甄选优质技术文档&#xff0c;服务群众&#xff01;作者&#xff1a;varlemon来源&#xff1a;https://www.cnblogs.com/connect/p/python-wechat-iciba.html图源&#xff1a;网络编辑&#xff1a;IT技术头条免责声明&#xff1a;1.本公众号所转载文章均来自公开网络…
阅读更多...
php页面添加链接,怎么给一个PHP密码访问页面加超链接

php页面添加链接,怎么给一个PHP密码访问页面加超链接

该楼层疑似违规已被系统折叠 隐藏此楼查看此楼$password "1234"; // 这里是密码$p "";if(isset($_COOKIE["isview"]) and $_COOKIE["isview"] $password){$isview true;}else{if(isset($_POST["pwd"])){if($_POST["…
阅读更多...
python 硬件模拟_如何编写一个硬件模拟器？

python 硬件模拟_如何编写一个硬件模拟器？

当下是短视频的时代&#xff0c;随着5g进程的加速推动&#xff0c;短视频已经成为了很多自媒体人变现的主要途径B站&#xff0c;抖音&#xff0c;快手&#xff0c;西瓜视频等等各大平台都砸钱鼓励平台创作者创作视频&#xff0c;因为平台流量大&#xff0c;我们就可以通过一些技…
阅读更多...
最新文章

Copyright @ 2022~2023