storm提交拓扑
2017-01-25 13:29:32 0 举报
Storm是一个分布式实时计算系统,用于处理大量数据流。提交拓扑是指将一个Storm应用部署到集群中并启动该应用的过程。在提交拓扑之前,需要编写一个Storm应用,并将其打包成jar文件。然后,使用Storm的提交命令将应用提交到集群中。提交成功后,Storm会在集群中启动该应用,并根据拓扑结构进行数据处理。Storm支持多种编程语言,如Java、Python和Scala。它提供了丰富的API,可以方便地处理数据流并进行实时分析。总之,提交拓扑是使用Storm进行实时数据处理的重要步骤。
作者其他创作
大纲/内容
飞盘
结束
是
ABASE
是否命中频控:未降权:7天降权:不发送
Counter TriggerMQ
否
是否命中频控:未降权:1天降权:7天
用户在站外:[10-23]点之间,发送站外push
判断用户是否在使用app
用户在站内:发送站内push
记录push发送的次数
是否是被圈定的用户
潜在用户
当天是否开播
使用不同的key
Dorado任务圈定「有开播行为的用户」列表和「潜在用户」列表
用户类别
vv数量是否达到阈值
飞盘接收小视频vv超过500的mq消息
判断用户是否需要降权:开播过的用户,有连续3次推送记录则设置为降权未开播过的用户,有连续2次推送记录则设置为降权
有过开播行为的用户
0 条评论
下一页