打电话产生的日志文件，经过Flume专门的海量日志信息的处理，然后又Kafka消息队列处理放入到HBase中，HBase中有数据了，在MapreReduce处理，到Hive数仓，或者到Yarn，经过自定义的Outoput到Mysql中去。Mysql到Web Service到spring framework或者spring MVC或者mybatis
我们将在Hbase中存储两个电话号码，以及通话建立的时间和通话持续时间，最后再加上一个flag作为判断第一个电话号码是否为主叫。姓名字段的存储我们可以放置于另外一张表做关联查询，也可以插入到当前表中。
相关文章：