大数据开发实战项目1-电信项目
producer.ProducerLog 主叫 -- 被叫 -- 通话建立时间 -- 通话持续时间 格式化,时间 流
utils.ConnectionInstance 连接初始化 utils.HbaseUtil 初始化hbase表格 utils.PropertiesUtil 获取配置文件的参数初始化
kafka.HBaseConsumer kafka获得从数据传入hbase
hbase.HBaseDAO 收到数据写入数据库 hbase.CalleeWriteObserver 协处理器,在收到数据的同时在f2加入被叫数据
两种方法:3.1sqoop 3.2Yarn(本项目选用)