HbaseAPI现需一张表a用于存放用户粉丝数据,可以存粉丝有谁,可以存关注了谁
时间: 2024-02-27 10:59:16 浏览: 76
Hbase的JavaAPI
你可以使用 HBase Java API 来创建并操作表 a。下面是一个示例代码,可以创建表 a 并将用户粉丝数据存储到其中。
```java
Configuration config = HBaseConfiguration.create();
Connection connection = ConnectionFactory.createConnection(config);
Admin admin = connection.getAdmin();
String tableName = "a";
TableName tn = TableName.valueOf(tableName);
HTableDescriptor tableDescriptor = new HTableDescriptor(tn);
HColumnDescriptor cfDescriptor = new HColumnDescriptor(Bytes.toBytes("f"));
tableDescriptor.addFamily(cfDescriptor);
admin.createTable(tableDescriptor);
Table table = connection.getTable(tn);
String rowKey = "user1";
String followKey = "follow";
String fansKey = "fans";
// 存储用户粉丝数据
Put put = new Put(Bytes.toBytes(rowKey));
put.addColumn(Bytes.toBytes("f"), Bytes.toBytes(followKey), Bytes.toBytes("user2,user3,user4"));
put.addColumn(Bytes.toBytes("f"), Bytes.toBytes(fansKey), Bytes.toBytes("user5,user6,user7"));
table.put(put);
// 获取用户粉丝数据
Get get = new Get(Bytes.toBytes(rowKey));
Result result = table.get(get);
byte[] followBytes = result.getValue(Bytes.toBytes("f"), Bytes.toBytes(followKey));
byte[] fansBytes = result.getValue(Bytes.toBytes("f"), Bytes.toBytes(fansKey));
String follow = Bytes.toString(followBytes);
String fans = Bytes.toString(fansBytes);
System.out.println("follow: " + follow);
System.out.println("fans: " + fans);
table.close();
connection.close();
```
在这个示例中,我们首先创建了一个名为 a 的表,并为其添加了一个名为 f 的列族。然后,我们使用 `Put` 对象向表中存储了一条用户粉丝数据,其中 row key 是 user1,follow 和 fans 列存储了用户的关注和粉丝数据。最后,我们使用 `Get` 对象从表中获取了用户粉丝数据,并将其输出到控制台。
需要注意的是,这个示例只是一个简单的示例,实际应用中,需要根据具体情况进行表的设计和数据存储。
阅读全文