educoder平台使用Java操作HBase

来源：用户分享时间：2025/6/5 9:11:53 本文由

说明：文章内容仅供预览，部分内容可能不全，需要完整文档或者需要复制内容，请下载word后使用。下载word有问题请添加微信号:xxxxxxx或QQ：xxxxxx 处理（尽可能给您提供完整文档），感谢您的支持与谅解。

1创建表

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; /**

* HBase 1.0 version of ExampleClient that uses {@code Connection}, * {@code Admin} and {@code Table}. */

public class Task{

public void createTable()throws Exception{ /********* Begin *********/

Configuration config = HBaseConfiguration.create();

Connection connection = ConnectionFactory.createConnection(config); try {

// Create table

Admin admin = connection.getAdmin(); try {

TableName tableName = TableName.valueOf(\ // 新API构建表

// TableDescriptor对象通过TableDescriptorBuilder构建； TableDescriptorBuilder tableDescriptor TableDescriptorBuilder.newBuilder(tableName); ColumnFamilyDescriptor family

ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes(\构建列族对象 tableDescriptor.setColumnFamily(family); // 设置列族 admin.createTable(tableDescriptor.build()); // 创建表

= =

TableName emp = TableName.valueOf(\

// 新API构建表

// TableDescriptor对象通过TableDescriptorBuilder构建； TableDescriptorBuilder empDescriptor = TableDescriptorBuilder.newBuilder(emp); ColumnFamilyDescriptor empfamily = ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes(\构建列族对象 empDescriptor.setColumnFamily(empfamily); // 设置列族 admin.createTable(empDescriptor.build()); // 创建表 } finally {

admin.close(); } } finally {

connection.close(); }

/********* End *********/ } }

命令行：

start-dfs.sh（Hadoop启动）回车

start-hbase.sh（hbase启动）测评

——————————————————————————————————————— 2添加数据 package step2;

import java.io.IOException;

import org.apache.hadoop.conf.Configuration;

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(\ TableDescriptorBuilder tableDescriptor TableDescriptorBuilder.newBuilder(tableName); ColumnFamilyDescriptor family

ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes(\构建列族对象 tableDescriptor.setColumnFamily(family); // 设置列族 admin.createTable(tableDescriptor.build()); // 创建表 //添加数据

byte[] row1 = Bytes.toBytes(\ Put put1 = new Put(row1);

byte[] columnFamily1 = Bytes.toBytes(\ //列

byte[] qualifier1 = Bytes.toBytes(String.valueOf(1)); //列族修饰词 byte[] value1 = Bytes.toBytes(\张三丰\ //值 put1.addColumn(columnFamily1, qualifier1, value1); byte[] row2 = Bytes.toBytes(\ Put put2 = new Put(row2);

= =

byte[] columnFamily2 = Bytes.toBytes(\ //列

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获取数据 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(\ Table table = connection.getTable(tableName);

//获取数据

Get get = new Get(Bytes.toBytes(\ //定义get对象

Result result = table.get(get); //通过table对象获取数据 //System.out.println(\

//很多时候我们只需要获取“值” 这里表示获取 data:1 列族的值

byte[] valueBytes = result.getValue(Bytes.toBytes(\获取到的是字节数组

//将字节转成字符串

String valueStr = new String(valueBytes,\-8\ System.out.println(\

TableName tableStep3Name = TableName.valueOf(\ 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(\Bytes.toBytes(1));

// System.out.println(\ byte[] row = scannerResult.getRow();

System.out.println(\-8\ } } finally {

scanner.close(); }

/********* End *********/ } }

测评

——————————————————————————————————————— 4删除表

package step4;

import java.io.IOException;

import org.apache.hadoop.conf.Configuration;

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(\ admin.disableTable(tableName); admin.deleteTable(tableName); /********* End *********/ } }

测评

搜索更多关于： educoder平台使用Java操作HBase 的文档

educoder平台使用Java操作HBase.doc 将本文的Word文档下载到电脑，方便复制、编辑、收藏和打印

下载这篇word文档

本文链接：https://www.diyifanwen.net/c0oc611daso77t6k14pg60zn011onzd01aks_1.html（转载请注明文章来源）