头哥实践平台----HBase 开发：使用Java操作HBase

一.第1关：创建表

1.先写命令行

start-dfs.shstart-hbase.shhadoop fs -ls /hbase(可有可无)

2.再写代码文件


package step1;import java.io.IOException;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.ColumnFamilyDescriptor;
import org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.ResultScanner;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.client.TableDescriptor;
import org.apache.hadoop.hbase.client.TableDescriptorBuilder;
import org.apache.hadoop.hbase.util.Bytes;public class Task{public void createTable()throws Exception{/********* Begin *********/Configuration config = HBaseConfiguration.create();Connection connection = ConnectionFactory.createConnection(config);try {// Create tableAdmin admin = connection.getAdmin();try {TableName tableName = TableName.valueOf("dept");// 新 API 构建表// TableDescriptor 对象通过 TableDescriptorBuilder 构建；TableDescriptorBuilder tableDescriptor =TableDescriptorBuilder.newBuilder(tableName);ColumnFamilyDescriptor family = ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes("data")).build();// 构建列族对象tableDescriptor.setColumnFamily(family); // 设置列族admin.createTable(tableDescriptor.build()); // 创建表TableName emp = TableName.valueOf("emp");// 新 API 构建表// TableDescriptor 对象通过 TableDescriptorBuilder 构建；TableDescriptorBuilder empDescriptor =TableDescriptorBuilder.newBuilder(emp);ColumnFamilyDescriptor empfamily =ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes("emp")).build();// 构建列族对象empDescriptor.setColumnFamily(empfamily); // 设置列族admin.createTable(empDescriptor.build()); // 创建表} finally {admin.close();}} finally {connection.close();}/********* End *********/}
}

3.运行

二.第2关：添加数据

1.先写命令行

start-dfs.shstart-hbase.sh

2.再写代码文件


package step2;import java.io.IOException;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.ColumnFamilyDescriptor;
import org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.ResultScanner;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.client.TableDescriptor;
import org.apache.hadoop.hbase.client.TableDescriptorBuilder;
import org.apache.hadoop.hbase.util.Bytes;public class Task {public void insertInfo()throws Exception{/********* Begin *********/Configuration config = HBaseConfiguration.create();Connection connection = ConnectionFactory.createConnection(config);Admin admin = connection.getAdmin();TableName tableName = TableName.valueOf("tb_step2");TableDescriptorBuilder tableDescriptor = TableDescriptorBuilder.newBuilder(tableName);ColumnFamilyDescriptor family = ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes("data")).build();//  构建列族对象tableDescriptor.setColumnFamily(family); //  设置列族admin.createTable(tableDescriptor.build()); //  创建表// 添加数据byte[] row1 = Bytes.toBytes("row1");Put put1 = new Put(row1); byte[] columnFamily1 = Bytes.toBytes("data"); // 列byte[] qualifier1 = Bytes.toBytes(String.valueOf(1)); // 列族修饰词byte[] value1 = Bytes.toBytes("张三丰"); // 值put1.addColumn(columnFamily1, qualifier1, value1);byte[] row2 = Bytes.toBytes("row2");Put put2 = new Put(row2); byte[] columnFamily2 = Bytes.toBytes("data"); // 列byte[] qualifier2 = Bytes.toBytes(String.valueOf(2)); // 列族修饰词byte[] value2 = Bytes.toBytes("张无忌"); // 值put2.addColumn(columnFamily2, qualifier2, value2);Table table = connection.getTable(tableName);table.put(put1);table.put(put2);/********* End *********/}
}

3.运行

三.第3关：获取数据

1.先写命令行

start-dfs.shstart-hbase.sh

2.再写代码文件

package step3;import java.io.IOException;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.ColumnFamilyDescriptor;
import org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.ResultScanner;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.client.TableDescriptor;
import org.apache.hadoop.hbase.client.TableDescriptorBuilder;
import org.apache.hadoop.hbase.util.Bytes;public class Task {public void queryTableInfo()throws Exception{/********* Begin *********/Configuration config = HBaseConfiguration.create();Connection connection = ConnectionFactory.createConnection(config);Admin admin = connection.getAdmin();TableName tableName = TableName.valueOf("t_step3");Table table = connection.getTable(tableName);// 获取数据Get get = new Get(Bytes.toBytes("row1")); // 定义 get 对象Result result = table.get(get); // 通过 table 对象获取数据//System.out.println("Result: " + result);// 很多时候我们只需要获取“值”   这里表示获取  data:1  列族的值byte[] valueBytes = result.getValue(Bytes.toBytes("data"), Bytes.toBytes("1")); // 获取到的是字节数组// 将字节转成字符串String valueStr = new String(valueBytes,"utf-8");System.out.println("value:" + valueStr);TableName tableStep3Name = TableName.valueOf("table_step3");Table step3Table = connection.getTable(tableStep3Name);// 批量查询Scan scan = new Scan();ResultScanner scanner = step3Table.getScanner(scan);try {int i = 0;for (Result scannerResult: scanner) {//byte[] value = scannerResult.getValue(Bytes.toBytes("data"), Bytes.toBytes(1));// System.out.println("Scan: " + scannerResult);byte[] row = scannerResult.getRow();System.out.println("rowName:" + new String(row,"utf-8"));}} finally {scanner.close();}/********* End *********/}}

3.运行

四.第4关：删除表

1.先写命令行

start-dfs.shstart-hbase.sh

2.再写代码文件


package step4;import java.io.IOException;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.ColumnFamilyDescriptor;
import org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.ResultScanner;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.client.TableDescriptor;
import org.apache.hadoop.hbase.client.TableDescriptorBuilder;
import org.apache.hadoop.hbase.util.Bytes;public class Task {public void deleteTable()throws Exception{/********* Begin *********/Configuration config = HBaseConfiguration.create();Connection connection = ConnectionFactory.createConnection(config);Admin admin = connection.getAdmin();TableName tableName = TableName.valueOf("t_step4");admin.disableTable(tableName);	admin.deleteTable(tableName);/********* End *********/}
}

3.运行

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

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

相关文章

unity3d模型中缺失animation

unity3d模型中缺失animation

在 模型的Rig-Animationtype 设置成Legacy https://tieba.baidu.com/p/2293580178
阅读更多...
时间戳，标准时间之间的转化

时间戳，标准时间之间的转化

一. 获取时间戳 方法一：Date.now() console.log(Date.now()) // 1701676212978方法二：Date.parse() Date.parse()将字符串或者时间对象直接转化成时间戳： Date.parse(new Date()) // 1701676571000 Date.parse("2023/12/04 15:53"…
阅读更多...
回文串+动态规划

回文串+动态规划

最长回文子串 遍历字符串，逐个判断每个字符，向两边扩散，判断以当前字符为中心，最长回文大小。 /*** ①中心扩散法* 向左 向右 向左右* ②动态规划优化* 空间换时间*/ class Solution {public static void main(String[] args) …
阅读更多...
OWASP SAMM 软件保障成熟度模型

OWASP SAMM 软件保障成熟度模型

软件保障成熟度模型 我们的使命是为您提供一种有效且可衡量的方式来分析和改进您的安全开发生命周期。 SAMM 支持完整的软件生命周期，并且与技术和流程无关。我们构建的 SAMM 本质上是不断发展和风险驱动的，因为没有一种单一的配方适用于所有组织。奥瓦…
阅读更多...
【图像拼接】论文精读：Pixel-wise Deep Image Stitching（PWM+SIGMo）

【图像拼接】论文精读：Pixel-wise Deep Image Stitching（PWM+SIGMo）

第一次来请先看这篇文章：【图像拼接（Image Stitching）】关于【图像拼接论文精读】专栏的相关说明，包含专栏使用说明、创新思路分享等（不定期更新） 图像拼接系列相关论文精读 Seam Carving for Content-Aware Image ResizingAs-Rigid-As-Possible Shape ManipulationAdap…
阅读更多...
【前端】甘特图或日历图

【前端】甘特图或日历图

前言 之前不是说了吗？公司文化就是让人来偷懒就偷懒的操作，于是乎就开始开发甘特图，可以让客户的员工以及领导能清晰地看见工作安排和生产排产情况。 技术选型 说实话使用什么技术可以兼容到现有系统里面，毕竟自己手写太浪费时间啦，于是乎就去GitHub上面找，真是尝试了…
阅读更多...
JVM——垃圾回收器（G1，JDK9默认为G1垃圾回收器）

JVM——垃圾回收器（G1，JDK9默认为G1垃圾回收器）

1.G1垃圾回收器 JDK9之后默认的垃圾回收器是G1（Garbage First）垃圾回收器。 Parallel Scavenge关注吞吐量，允许用户设置最大暂停时间 ，但是会减少年轻代可用空间的大小。 CMS关注暂停时间，但是吞吐量方面会下降。 而G1…
阅读更多...
【C语言】扫雷小游戏初学者版

【C语言】扫雷小游戏初学者版

成功的秘诀就是每天都比别人多努力一点。 今天给大家带来一款非常经典的小游戏——扫雷的实现和讲解 这里是目录 前言整体框架1.打印菜单2.创建二维数组3.初始化棋盘4.打印棋盘5.布置棋盘中的雷6.排查雷和统计雷总体代码test.cgame.cgame.h 进阶（递归展开&#xff0…
阅读更多...
CityEngine2023 shp数据城市与路网三维模型并导入UE5

CityEngine2023 shp数据城市与路网三维模型并导入UE5

目录 0 引言1 城市和道路数据获取1.1 常用方法1.2 OSM数据获取1.3 OSM数据格式1.3.1 所有格式1.3.2 Shapefile格式 2 实践2.1 导入数据（.shp）2.2 构建三维模型2.3 将模型导入UE5 🙋‍♂️ 作者：海码007📜 专栏&#xf…
阅读更多...
手机传输数据到电脑该怎么操作？安卓、苹果都可以这样操作

手机传输数据到电脑该怎么操作？安卓、苹果都可以这样操作

安卓手机 你知道安卓手机传输数据到电脑的方法有哪些吗？下面我们就一起来看一看可以使用的一些方法。 采用 USB 数据线 这个方法应该是我们生活中较为常见的方法了，我们只需要使用手机的充电线，将其连接到电脑上，然后手机可能会…
阅读更多...
Motion Plan之轨迹生成笔记 (2)

Motion Plan之轨迹生成笔记 (2)

Motion Plan之搜索算法笔记 Motion Plan之基于采样的路径规划算法笔记 Motion Plan之带动力学约束路径搜索 什么是基于优化的轨迹生成 Optimization-Based Trajectory Planning（基于优化的轨迹规划）是一种常用的方法，用于生成自动化系统&am…
阅读更多...
2.4 API 开发和集成

2.4 API 开发和集成

文章目录 API 开发和集成API 的概念和作用API 开发基础API 集成API 鉴权和安全API 文档和测试微服务和 API 网关云服务和 API 集成未来趋势和发展实验实验一： 通过api post方式传入 json实验二：通过api将所需数据传入 API 开发和集成 API 的概念和作用介…
阅读更多...
StarRocks上新，“One Data、All Analytics”还有多远？

StarRocks上新，“One Data、All Analytics”还有多远？

K.K在《未来十二大趋势》中认为，我们正处于一个数据流动的时代。商业乃数据之商业。归根结底，你在处理的都是数据。 的确，当数据成为新的核心生产要素之际，数据分析就犹如最重要的生产工具之一，决定着企业在数字化时代…
阅读更多...
Python爬虫超详细讲解（零基础入门，包教包会）

Python爬虫超详细讲解（零基础入门，包教包会）

先看后赞，养成习惯。 点赞收藏，人生辉煌。 讲解我们的爬虫之前，先概述关于爬虫的简单概念（毕竟是零基础教程） 爬虫 网络爬虫（又被称为网页蜘蛛，网络机器人）就是模拟浏览器发送网络…
阅读更多...
贝叶斯分类器（Bayesian Classifier）

贝叶斯分类器（Bayesian Classifier）

贝叶斯分类器（Bayesian Classifier）详解 贝叶斯分类器是基于贝叶斯定理的一类统计分类方法。它们在给定数据的条件下，通过计算不同类别的概率来进行分类。 贝叶斯定理 贝叶斯定理是贝叶斯分类器的核心，它提供了在已知某些信息的…
阅读更多...
InsCode实践分享：一款强大的Web代码编辑器

InsCode实践分享：一款强大的Web代码编辑器

InsCode是一款基于Web的代码编辑器，它提供了丰富的功能和便捷的操作界面，可以满足程序员在编写、调试和分享代码方面的各种需求。本文将从以下几个方面介绍InsCode的实践分享：使用体验、主要功能、扩展应用、团队协作和未来发展。 一、使用体…
阅读更多...
es6 相关面试总结

es6 相关面试总结

1、es6 是什么 新一代的js 语言标准，对其核心做了升级优化，更加适合大型应用开发。 2、箭头函数优缺点 优点： 1.代码优化 2.this 指向不会变动，永远指向其父元素 缺点： 1.没有arguments 参数 2.不能通过 apply call bind改变this指向 不能用箭头函数的场景： 1.构…
阅读更多...
【Avue】select的远程搜索 [模糊搜索]

【Avue】select的远程搜索 [模糊搜索]

一、需求 【模糊搜索】 二、实现avue的远程搜索 1、search为搜索 2、remote远程搜索 3、dictValue{{key}}为输入的值
阅读更多...
JS 排序学习记录

JS 排序学习记录

排序 1、快速排序 快速排序（Quick Sort）是一种常用的排序算法，其原理基于分治策略。快速排序的基本思想是通过选择一个基准元素（pivot），将待排序序列分割成两部分，一部分所有元素小于等于基准…
阅读更多...
数实融合！低代码推动工业数字化转型走“深”向“实”

数实融合！低代码推动工业数字化转型走“深”向“实”

当下，“数字化、智能化”已经不再是新鲜词。毕竟，在早几年前就已经有企业喊出大举进军数字化的口号，轰轰烈烈的数字化转型运动也持续了很长一段时间，有一些业内人士甚至判断“如今的企业数字化已经走过了成熟期，来到了…
阅读更多...
最新文章

Copyright @ 2022~2023