当我使用storm作为过滤器时,我可以动态更改条件吗?

gcxthw6b  于 2021-06-21  发布在  Storm
关注(0)|答案(1)|浏览(225)

我一直在阅读关于storm的文档,并在google上搜索关于我的问题,但是我仍然没有找到方法通过storm来处理我的用例。
我的用例:我使用storm作为过滤器,但是过滤器的条件会被客户端动态地改变,然后storm会输出符合当前过滤器条件的结果。
让我困惑的是客户端如何与storm通信来动态改变过滤条件?还是我看错了?如果是的话,你为这个用例提出了什么替代方案?

xlpyo6sf

xlpyo6sf1#

由于准备好的喷口/螺栓可以存储状态,因此将过滤条件放入其中是一种解决方案。
有多种方法可以动态地改变它们。例如:
将一些特殊的元组发送到拓扑中,表示所做的更改。
将过滤条件存储在zookeeper或类似的东西中。在bolt中存储一个库管理员侦听器,它可以动态应用更改。

相关问题