5.8 Java操作HBase

2024-06-07 19:18
文章标签 java 操作 hbase 5.8

本文主要是介绍5.8 Java操作HBase,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

HBase模糊查询: 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();
}
}
}

这篇关于5.8 Java操作HBase的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1040058

相关文章

java中BigDecimal里面的subtract函数介绍及实现方法

《java中BigDecimal里面的subtract函数介绍及实现方法》在Java中实现减法操作需要根据数据类型选择不同方法,主要分为数值型减法和字符串减法两种场景,本文给大家介绍java中BigD... 目录Java中BigDecimal里面的subtract函数的意思?一、数值型减法(高精度计算)1.

Java空指针异常NullPointerException的原因与解决方案

《Java空指针异常NullPointerException的原因与解决方案》在Java开发中,NullPointerException(空指针异常)是最常见的运行时异常之一,通常发生在程序尝试访问或... 目录一、空指针异常产生的原因1. 变量未初始化2. 对象引用被显式置为null3. 方法返回null

Python使用Code2flow将代码转化为流程图的操作教程

《Python使用Code2flow将代码转化为流程图的操作教程》Code2flow是一款开源工具,能够将代码自动转换为流程图,该工具对于代码审查、调试和理解大型代码库非常有用,在这篇博客中,我们将深... 目录引言1nVflRA、为什么选择 Code2flow?2、安装 Code2flow3、基本功能演示

一文彻底搞懂Java 中的 SPI 是什么

《一文彻底搞懂Java中的SPI是什么》:本文主要介绍Java中的SPI是什么,本篇文章将通过经典题目、实战解析和面试官视角,帮助你从容应对“SPI”相关问题,赢得技术面试的加分项,需要的朋... 目录一、面试主题概述二、高频面试题汇总三、重点题目详解✅ 面试题1:Java 的 SPI 是什么?如何实现一个

Spring中管理bean对象的方式(专业级说明)

《Spring中管理bean对象的方式(专业级说明)》在Spring框架中,Bean的管理是核心功能,主要通过IoC(控制反转)容器实现,下面给大家介绍Spring中管理bean对象的方式,感兴趣的朋... 目录1.Bean的声明与注册1.1 基于XML配置1.2 基于注解(主流方式)1.3 基于Java

SpringCloud中的@FeignClient注解使用详解

《SpringCloud中的@FeignClient注解使用详解》在SpringCloud中使用Feign进行服务间的调用时,通常会使用@FeignClient注解来标记Feign客户端接口,这篇文章... 在Spring Cloud中使用Feign进行服务间的调用时,通常会使用@FeignClient注解

Java Spring 中的监听器Listener详解与实战教程

《JavaSpring中的监听器Listener详解与实战教程》Spring提供了多种监听器机制,可以用于监听应用生命周期、会话生命周期和请求处理过程中的事件,:本文主要介绍JavaSprin... 目录一、监听器的作用1.1 应用生命周期管理1.2 会话管理1.3 请求处理监控二、创建监听器2.1 Ser

Python中OpenCV与Matplotlib的图像操作入门指南

《Python中OpenCV与Matplotlib的图像操作入门指南》:本文主要介绍Python中OpenCV与Matplotlib的图像操作指南,本文通过实例代码给大家介绍的非常详细,对大家的学... 目录一、环境准备二、图像的基本操作1. 图像读取、显示与保存 使用OpenCV操作2. 像素级操作3.

JVisualVM之Java性能监控与调优利器详解

《JVisualVM之Java性能监控与调优利器详解》本文将详细介绍JVisualVM的使用方法,并结合实际案例展示如何利用它进行性能调优,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全... 目录1. JVisualVM简介2. JVisualVM的安装与启动2.1 启动JVisualVM2

Java如何从Redis中批量读取数据

《Java如何从Redis中批量读取数据》:本文主要介绍Java如何从Redis中批量读取数据的情况,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一.背景概述二.分析与实现三.发现问题与屡次改进3.1.QPS过高而且波动很大3.2.程序中断,抛异常3.3.内存消