java - Storm : get input fields in prepare()

Question

其实这个问题来自于我的编程思路:在 fieldsGrouping() 中，具有相同值的输入字段将执行 Bolt 的相同任务。是否可以在 prepare() 期间或 execute() 之前获取输入字段的值？

实际上，我想为任务分配一个唯一的id，无论相同的拓扑重新启动。

Answer 1

如果了解哪些任务处理哪些值对您来说很重要，您可以查看定向流，您不仅可以为其发出元组和流 ID，还可以发出用于处理元组的组件实例的任务 ID 。您基本上是自己实现字段分组。这需要做更多的工作，但至少您知道在prepare() 中什么值去了哪里，因为这是您的逻辑决定的。