我想检测数据流中丢失的事件（例如，检测在收到请求后1小时内未得到响应的客户请求）在这里，我想检测“响应”事件并发出警报。
我尝试通过设置topology\u tick\u tuple\u freq\u secs来使用tick tuple，但它是在螺栓级别配置的，可能在收到客户请求的第15分钟之后出现。
@重写公共Mapgetcomponentconfiguration（）{
Config conf = new Config();
conf.put(Config.TOPOLOGY_TICK_TUPLE_FREQ_SECS, 1800);
return conf; }^这不管用。
如果需要任何其他信息，请在评论中告诉我。事先谢谢你的帮助。
1条答案
按热度按时间6vl6ewon1#
这也许会有帮助http://storm.apache.org/releases/1.0.3/windowing.html
您可以定义5分钟窗口，并根据接收到的内容检查上一个窗口事件和警报的状态
或者创建一个中间螺栓来维护这些窗口，并在超时时发送正常的警报元组（而不是tick元组）