大数据之HBase 实战微博系统 完整使用 (第六章)

• 一、需求分析
• 二、代码实现
• • 2.1 代码设计总览
  • 2.2 创建命名空间以及表名的定义
  • 2.3 创建微博内容表
  • 2.4 创建用户关系表
  • 2.5 创建微博收件箱表
  • 2.6 发布微博内容
  • 2.7 添加关注用户
  • 2.8 移除（取关）用户
  • 2.9 获取关注的人的微博内容
  • 2.10 测试

1. 微博内容的浏览，数据库表设计
2. 用户社交体现：关注用户，取关用户
3. 拉取关注的人的微博内容

1. 创建命名空间以及表名的定义
2. 创建微博内容表
3. 创建用户关系表
4. 创建用户微博内容接收邮件表
5. 发布微博内容 6)
   添加关注用户
6. 移除（取关）用户
7. 获取关注的人的微博内容
8. 测试

package org.example.contants;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HbaseConfiguration;

public class Constants {

    //Hbase配置信息
    public static Configuration ConFIGURATION = HbaseConfiguration.create();

    //Hbase命名空间
    public static String NAMESPACE = "weibo";

    //微博内容表
    public static String CONTENT_TABLE = "weibo:content";
    public static String CONTENT_TABLE_CF = "info";
    public static int CONTENT_TABLE_VERSIONS = 1;

    //用户关系表
    public static String RELATION_TABLE = "weibo:relation";
    public static String RELATION_TABLE_CF1 = "attends";
    public static String RELATION_TABLE_CF2 = "fans";
    public static int RELATION_TABLE_VERSIONS = 1;

    //收件箱表
    public static String INBOX_TABLE = "weibo:index";
    public static String INBOX_TABLE_CF = "info";
    public static int INBOX_TABLE_VERSIONS = 2;

}