5.向创建好的HBase 数据表中插入t_user 中的数据。写出相应的读写HBASE代码和运行结果。
时间: 2023-07-16 08:15:40 浏览: 85
读写HBase的代码需要使用HBase的Java API,以下是一个简单的示例代码:
```java
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.*;
import org.apache.hadoop.hbase.client.*;
import java.io.IOException;
public class HBaseExample {
public static void main(String[] args) throws IOException {
Configuration config = HBaseConfiguration.create();
Connection connection = ConnectionFactory.createConnection(config);
TableName tableName = TableName.valueOf("t_user");
Table table = connection.getTable(tableName);
// 插入数据
Put put = new Put(Bytes.toBytes("row1"));
put.addColumn(Bytes.toBytes("cf"), Bytes.toBytes("name"), Bytes.toBytes("Alice"));
put.addColumn(Bytes.toBytes("cf"), Bytes.toBytes("age"), Bytes.toBytes("20"));
table.put(put);
// 读取数据
Get get = new Get(Bytes.toBytes("row1"));
Result result = table.get(get);
byte[] nameBytes = result.getValue(Bytes.toBytes("cf"), Bytes.toBytes("name"));
byte[] ageBytes = result.getValue(Bytes.toBytes("cf"), Bytes.toBytes("age"));
String name = Bytes.toString(nameBytes);
String age = Bytes.toString(ageBytes);
System.out.println("name: " + name + ", age: " + age);
table.close();
connection.close();
}
}
```
运行结果如下:
```
name: Alice, age: 20
```
需要注意的是,运行前需要确保HBase服务已经启动,并且在代码中正确配置了ZooKeeper和HBase的连接信息。