HBase 代码_2| 学习笔记

简介: 快速学习 HBase 代码_2

开发者学堂课程【HBase 入门教程HBase 代码_2】学习笔记,与课程紧密联系,让用户快速学习知识。

课程地址:https://developer.aliyun.com/learning/course/397/detail/5074


HBase 代码_2


一、创建查询通话详单项目示例

代码示例:

package com.sxt.hbase;

import org.apache.hadoop.conf.Configuration;

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

import org.junit.Before;

public class HBaseDemo {

public void begin ( ) throws Exceptiont{

Configuration conf = new Configuration ( );

HBaseAdmin hBaseAdmin;

HBaseAdmin hBaseAdmin;

HTable hTable;

String TN = “phone”;

@Before

public void begin () throws Exception {

configuration conf = new Configuration ( );

conf.set(“hbase.zookeeper.quorum”,”node1,node2,node3”);

//指定 zookeeper 集群

hBaseAdmin = new HBaseAdmin (conf);

//新的参数可以直接携带一个 String 类,变量名称中 familyname 是列族的名称

//初始化 HTable 对象  hTable = new htableconf,TN

}

@After

public void end () {

if (hBaseAdmin != null){

try {

hBaseAdmin.close ( );

}catch (IOException e){

e.printstackTrace ( );

}

}

if (hTable ! = null){

//释放

try{

hTable.close();

}catch (IOException e){

e.printStackTrace();

}

}

}

@Test

public void createTbl throws Exception(){

if(hBaseAdmin.tableExists (TN)){

//判断表是否存在

hBaseAdmin.disableTable (TN);

//如果存在

hBaseAdmin.deleteTable(TN);

//如果表存在则进行数据删除

}

HTableDescriptor desc = new HTableDescriptor(TableName.valueOf(TN);

//创建一个新的表名

//返回参数 tablename

//添加关于表的描述

HColumnDescriptor family = new HColumnDescriptor ("cf1");

//familyname 表示列族的名称

//如果需要查询的字段很多,列行非常多,建议建立的 habse 不要

23个列族,否则无法进行支撑。列族有一个限制,最佳范围

13个。

Hbase 官网介绍:

Chapter 35. On the number of column families

HBase currently does not do well with anything above two or

three column families so keep thenumber of column families in

your schema low.HBase目前不能很好地处理超过2 - 3个列族的情况,所以请将你的模式中的列族数量保持在较低的水平。Currently,flushing and compactions are done

on a perRegion basis so if one column family is carrying the

bulk of the data bringing on flushes, the adjacentfamilies will

also be flushed even though the amount of data they carry is

small. When many columnfamilies exist the flushing and

compaction interaction can make for a bunch of needless i/o

(To beaddressed by changing flushing and compaction to work

on a per column family basis). For moreinformation on

compactions, see Compaction.

Try to make do with one column family if you can in your

schemas. Only introduce a second and thirdcolumn family in

the case where data access is usually column scoped;i.e. you

query one columnfamily or the other but usually not both at the

one time.

35.1. Cardinality of ColumnFamilies

Where multiple ColumnFamilies exist in a single table, be aware

of the cardinality (i.e. number ofrows).If ColumnFamilyA has 1

million rows and ColumnFamilyB has 1 billion rows,

ColumnFamilyA'sdata will likely be spread across many, many

regions (and RegionServers). This makes mass scans

forColumnFamilyA less efficient.

//在创建表时必须指定列族,指定列族中含有 addFamily

family.setBlockCacheEnabled (true);

//读取缓存

family.setInMemory (true);

//是否加载

family.setMaxvVersions(1);

//最大版本数默认为1

desc.addFamily (family);

//指定列族

hBaseAdmin.createTable (desc);

//TTL 对应 in time ToLive:当业务中,数据需要定时销毁时,就可以使用此函数。

}

//添加数据的方法

public void insert( )throws Exception{

string rowkey =””;

//定义 rowkey

//查询两种方式:

1.scan

2.get

Put put = new Put(rowkey.getBytes());

hTable.put (put);

}

}

//当在编写 hbase时,将 hbase 文件直接放置进文件夹也许会报错,需要用户手动指定 hbase 配置文件,需要指定zookeeper 集群。

进入后端输入 hbase shell 和 list 查看项目是否创建成功,显示如下:
image.png

输入 describe ‘phone’ 进行表明,出现如下:

image.png

表创建成功。

相关实践学习
lindorm多模间数据无缝流转
展现了Lindorm多模融合能力——用kafka API写入,无缝流转在各引擎内进行数据存储和计算的实验。
云数据库HBase版使用教程
  相关的阿里云产品:云数据库 HBase 版 面向大数据领域的一站式NoSQL服务,100%兼容开源HBase并深度扩展,支持海量数据下的实时存储、高并发吞吐、轻SQL分析、全文检索、时序时空查询等能力,是风控、推荐、广告、物联网、车联网、Feeds流、数据大屏等场景首选数据库,是为淘宝、支付宝、菜鸟等众多阿里核心业务提供关键支撑的数据库。 了解产品详情: https://cn.aliyun.com/product/hbase   ------------------------------------------------------------------------- 阿里云数据库体验:数据库上云实战 开发者云会免费提供一台带自建MySQL的源数据库 ECS 实例和一台目标数据库 RDS实例。跟着指引,您可以一步步实现将ECS自建数据库迁移到目标数据库RDS。 点击下方链接,领取免费ECS&RDS资源,30分钟完成数据库上云实战!https://developer.aliyun.com/adc/scenario/51eefbd1894e42f6bb9acacadd3f9121?spm=a2c6h.13788135.J_3257954370.9.4ba85f24utseFl
相关文章
|
存储 SQL 自然语言处理
基于 HBase 的海量数据查询与检索解析|学习笔记
快速学习基于 HBase 的海量数据查询与检索解析
基于 HBase 的海量数据查询与检索解析|学习笔记
|
6月前
|
SQL 分布式计算 Hadoop
Hadoop学习笔记(HDP)-Part.16 安装HBase
01 关于HDP 02 核心组件原理 03 资源规划 04 基础环境配置 05 Yum源配置 06 安装OracleJDK 07 安装MySQL 08 部署Ambari集群 09 安装OpenLDAP 10 创建集群 11 安装Kerberos 12 安装HDFS 13 安装Ranger 14 安装YARN+MR 15 安装HIVE 16 安装HBase 17 安装Spark2 18 安装Flink 19 安装Kafka 20 安装Flume
137 1
Hadoop学习笔记(HDP)-Part.16 安装HBase
|
存储 前端开发 Cloud Native
基于 HBase 快速构架海量订单存储系统|学习笔记
快速学习基于 HBase 快速构架海量订单存储系统
基于 HBase 快速构架海量订单存储系统|学习笔记
|
存储 搜索推荐 Java
如何基于 HBase 构建图片、视频数据的统一存储检索方案|学习笔记
快速学习如何基于 HBase 构建图片、视频数据的统一存储检索方案
如何基于 HBase 构建图片、视频数据的统一存储检索方案|学习笔记
|
SQL 存储 边缘计算
HBase&Hive 2(三)|学习笔记
快速学习 HBase&Hive 2(三)
131 0
HBase&Hive 2(三)|学习笔记
|
SQL 存储 分布式计算
HBase&Hive 2(二)|学习笔记
快速学习 HBase&Hive 2(二)
HBase&Hive 2(二)|学习笔记
|
存储 SQL 分布式计算
HBase&Hive 2(一)|学习笔记
快速学习 HBase&Hive 2(一)
116 0
HBase&Hive 2(一)|学习笔记
|
存储 SQL 缓存
HBase&HIve 1|学习笔记
快速学习 HBase&HIve 1
172 0
HBase&HIve 1|学习笔记
|
SQL 消息中间件 存储
基于 HBase 的大数据在线分析|学习笔记
快速学习基于 HBase 的大数据在线分析
基于 HBase 的大数据在线分析|学习笔记
|
XML 缓存 分布式计算
集成 Oozie 服务&集成 Hbase 服务 | 学习笔记
快速学习 集成 Oozie 服务&集成 Hbase 服务
101 0
集成 Oozie 服务&集成 Hbase 服务 | 学习笔记