阅读背景:

stream延时十分钟处理数据

来源:互联网 

解决方案:

用plsql来处理逻辑

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




你的当前访问异常,请进行认证后继续阅读剩余内容。

分享到: