hbase好友表设计

需求：

• 添加关注
• 查看关注
• 添加粉丝
• 查看粉丝

创建表

@Test
public void createTable() throws Exception {
 if(admin.tableExists(TN1)) {
  //先禁用这个表
  admin.disableTable(TN1);
  //删除
  admin.deleteTable(TN1);
 }
 //表描述
 HTableDescriptor desc=new HTableDescriptor(TableName.valueOf(TN1));
 //列族
 HColumnDescriptor cf = new HColumnDescriptor("cf1".getBytes());
 HColumnDescriptor cf2 = new HColumnDescriptor("cf2".getBytes());
 //列族加到表描述里
 desc.addFamily(cf);
 desc.addFamily(cf2);
 admin.createTable(desc);
}

添加数据

首先添加001用户的好友

@Test
public void scan2() throws Exception {
 FilterList list = new FilterList(FilterList.Operator.MUST_PASS_ALL);
 PrefixFilter filter1 = new PrefixFilter("001".getBytes());
 //添加过滤器
 list.addFilter(filter1);
 Scan scan = new Scan();
 scan.setFilter(list);
 ResultScanner rss = htable.getScanner(scan);
 for (Result rs:rss) {
  System.out.print(new String(CellUtil.cloneValue(rs.getColumnLatestCell("cf1".getBytes(), "fensi".getBytes()))));
 }
}

查看粉丝

@Test
public void scan2() throws Exception {
 FilterList list = new FilterList(FilterList.Operator.MUST_PASS_ALL);
 PrefixFilter filter1 = new PrefixFilter("001".getBytes());
 //添加过滤器
 list.addFilter(filter1);
 Scan scan = new Scan();
 scan.setFilter(list);
 ResultScanner rss = htable.getScanner(scan);
 for (Result rs:rss) {
  System.out.print(new String(CellUtil.cloneValue(rs.getColumnLatestCell("cf1".getBytes(), "fensi".getBytes()))));
 }
}