使用 API 在 HBase 中创建 Stu_Class 表
时间: 2024-03-20 13:40:02 浏览: 97
hbase API
4星 · 用户满意度95%
可以通过 HBase 的 Java API 来创建 Stu_Class 表。
以下是实现的步骤:
1. 创建 Configuration 对象,并设置 HBase 的配置信息:
```java
Configuration config = HBaseConfiguration.create();
config.set("hbase.zookeeper.quorum", "localhost"); // ZooKeeper 地址
config.set("hbase.zookeeper.property.clientPort", "2181"); // ZooKeeper 端口
```
2. 创建 HBaseAdmin 对象:
```java
HBaseAdmin admin = new HBaseAdmin(config);
```
3. 创建表描述器 HTableDescriptor 对象:
```java
HTableDescriptor tableDescriptor = new HTableDescriptor(TableName.valueOf("Stu_Class")); // 表名
```
4. 添加表列族:
```java
HColumnDescriptor columnDescriptor = new HColumnDescriptor("info"); // 列族名
tableDescriptor.addFamily(columnDescriptor);
```
5. 创建表:
```java
admin.createTable(tableDescriptor);
```
完整的示例代码如下:
```java
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.HBaseAdmin;
import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.HColumnDescriptor;
import java.io.IOException;
public class CreateStuClassTable {
public static void main(String[] args) throws IOException {
// 创建 Configuration 对象
Configuration config = HBaseConfiguration.create();
config.set("hbase.zookeeper.quorum", "localhost"); // ZooKeeper 地址
config.set("hbase.zookeeper.property.clientPort", "2181"); // ZooKeeper 端口
// 创建 HBaseAdmin 对象
HBaseAdmin admin = new HBaseAdmin(config);
// 创建表描述器 HTableDescriptor 对象
HTableDescriptor tableDescriptor = new HTableDescriptor(TableName.valueOf("Stu_Class")); // 表名
// 添加表列族
HColumnDescriptor columnDescriptor = new HColumnDescriptor("info"); // 列族名
tableDescriptor.addFamily(columnDescriptor);
// 创建表
admin.createTable(tableDescriptor);
// 关闭连接
admin.close();
}
}
```
注意:在运行上述程序之前,请先启动 HBase 服务。
阅读全文