解决方案:
用plsql来处理逻辑
用户点击产生日志-->flume收集日志-->传给kafka中的消息队列-->创建stream表接收流中的数据-->将数据插入hyperbase中,时间戳拼接uuid做主键-->从hyperbase中按照key消费当前时间前减去十分钟的时间的数据-->如果没有数据就sleep-->从hyperbase接到的数据再做解析用户点击产生日志-->flume收集日志--
解决方案:
用plsql来处理逻辑
用户点击产生日志-->flume收集日志-->传给kafka中的消息队列-->创建stream表接收流中的数据-->将数据插入hyperbase中,时间戳拼接uuid做主键-->从hyperbase中按照key消费当前时间前减去十分钟的时间的数据-->如果没有数据就sleep-->从hyperbase接到的数据再做解析用户点击产生日志-->flume收集日志--