5.8 Java操作HBase

女爷i 2022-05-22 00:22 186阅读 0赞

HBase模糊查询： [http://www.cnblogs.com/seaspring/p/5631933.html][http_www.cnblogs.com_seaspring_p_5631933.html]

/\*\*

\* <p>内容描述：操作HBase</p>

\* @author lvjie

\* @date 2017年7月7日 上午11:54:20

\*/

public class UseHbase \{

public static String TN = "tab1";

/\*\*

\* 创建表

\* @param tb

\* @throws IOException

\*/

public void createTab(String tb,HBaseAdmin hBaseAdmin) throws IOException\{

//查看表是否存在，存在就废弃，删除

if(hBaseAdmin.tableExists(TN)) \{

hBaseAdmin.disableTable(TN);//废弃表

hBaseAdmin.deleteTable(TN);//删除表

\}

//定义表名

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

//定义列族

HColumnDescriptor family = new HColumnDescriptor("cf");

family.setInMemory(true);

family.setMaxVersions(1);

desc.addFamily(family);

hBaseAdmin.createTable(desc);

\}

/\*\*

\* 插入数据

\* @param htable

\* @throws Exception

\*/

public void insertDB(HTable htable) throws Exception \{

//rowkey设计

Put put = new Put("18612341234\_15525353434".getBytes());

put.add("cf".getBytes(), "name".getBytes(), "zhangsan".getBytes());

htable.put(put);

\}

/\*\*

\* 查询 某些cell

\* @throws Exception

\*/

public void getDB(HTable htable) throws Exception \{

// 参数:rowkey设计

Get get = new Get("18612341234\_15525353434".getBytes());

get.addColumn("cf".getBytes(), "name".getBytes());

Result rs = htable.get(get);

Cell cell = rs.getColumnLatestCell("cf".getBytes(), "name".getBytes());

System.out.println(new String(CellUtil.cloneValue(cell)));

\}

public static void main(String\[\] args) \{

Configuration conf = new Configuration();

conf.set("hbase.zookeeper.quorum", "node1");

try \{

HBaseAdmin hBaseAdmin = new HBaseAdmin(conf);

HTable htable = new HTable(conf, TN);

UseHbase use = new UseHbase();

//use.createTab(TN,hBaseAdmin);

//use.insertDB(htable);

use.getDB(htable);

\} catch (Exception e) \{

// TODO Auto-generated catch block

e.printStackTrace();

\}

\}

\}

[http_www.cnblogs.com_seaspring_p_5631933.html]: http://www.cnblogs.com/seaspring/p/5631933.html

发表评论取消回复

表情：

评论列表（有 0 条评论，186人围观）

还没有评论，来说两句吧...

相关阅读

相关使用Java操作Hbase

目录修改hosts文件导入jar包配置hbase信息，连接hbase数据库创建表删除表获取namespace 获取tables 添加数据查询表中

快来打我*/ 2024年03月26日 19:18/ 0 赞/ 44 阅读

相关 Java连接HBase数据库，操作HBase数据库

　　最近学习了下HBase，面向列的数据库，属于NoSql范畴。通过编写Java代码来连接HBase数据库。　　Hadoop+HBase环境已经装好，然后利用Java

本是古典何须时尚/ 2023年09月25日 11:50/ 0 赞/ 37 阅读

相关【HBase】Java 操作 HBase 超详细示例（转）

> 原文链接：[http://blog.csdn.net/u010967382/article/details/37878701][http_blog.csdn.net_u01

淡淡的烟草味﹌/ 2022年11月19日 07:54/ 0 赞/ 583 阅读

相关 java操作hbase例子

hbase安装方法请参考：[hbase-0.94安装方法详解][hbase-0.94] hbase常用的shell命令请参考：[hbase常用的shell命令例子][hbas

怼烎@/ 2022年08月02日 14:43/ 0 赞/ 161 阅读

相关 hbase的java操作

操作hbase的分为两种，一种ddl dml，一种是获得HBaseAdmin（见表删表），一种是获得HTable（增删改查）代码： import java.io.

川长思鸟来/ 2022年07月11日 23:57/ 0 赞/ 171 阅读

相关 java操作hbase基础

public class HbaseDemo { private static Configuration conf =null; static{

旧城等待，/ 2022年06月16日 09:43/ 0 赞/ 168 阅读

相关 java api操作hbase

package com.sanlen.hbase.demo; import java.io.IOException; import java.util.Array

红太狼/ 2022年06月10日 13:21/ 0 赞/ 175 阅读

相关 java 操作HBase

HBase本身是有java实现的，通过javaapi可以进行高效的访问需要导入HBase/lib目录下所有jar package com.cyh;

╰+哭是因爲堅強的太久メ/ 2022年06月07日 07:47/ 0 赞/ 175 阅读

相关 java操作hbase数据库

mport java.io.IOException; import org.apache.hadoop.conf.Configuration;

Myth丶恋晨/ 2022年06月05日 00:52/ 0 赞/ 191 阅读

相关 HBase——MapReduce操作HBase

本节目标：掌握编写MR操作HBase。通过[官方实例][Link 1]，可以看到自定义map函数要继承TableMapper，自定义reduce函数要继承TableRe

谁践踏了优雅/ 2022年05月26日 07:16/ 0 赞/ 370 阅读