我一直在阅读关于storm的文档，并在google上搜索关于我的问题，但是我仍然没有找到方法通过storm来处理我的用例。我的用例：我使用storm作为过滤器，但是过滤器的条件会被客户端动态地改变，然后storm会输出符合当前过滤器条件的结果。让我困惑的是客户端如何与storm通信来动态改变过滤条件？还是我看错了？如果是的话，你为这个用例提出了什么替代方案？
xlpyo6sf1#
由于准备好的喷口/螺栓可以存储状态，因此将过滤条件放入其中是一种解决方案。有多种方法可以动态地改变它们。例如：将一些特殊的元组发送到拓扑中，表示所做的更改。将过滤条件存储在zookeeper或类似的东西中。在bolt中存储一个库管理员侦听器，它可以动态应用更改。
1条答案
按热度按时间xlpyo6sf1#
由于准备好的喷口/螺栓可以存储状态，因此将过滤条件放入其中是一种解决方案。
有多种方法可以动态地改变它们。例如：
将一些特殊的元组发送到拓扑中，表示所做的更改。
将过滤条件存储在zookeeper或类似的东西中。在bolt中存储一个库管理员侦听器，它可以动态应用更改。