需求:
- 添加关注
- 查看关注
- 添加粉丝
- 查看粉丝
rowkey | cf1(关注列表) | cf2(粉丝列表) |
001 | 002 | 003 |
002 | 001 | |
003 | 001 |
创建表
@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())))); } }

可以
给你点赞
我也是小白以后多多交流
挺明白的
挺明白的