实际上，这个问题来自于我的编程思想：在 fieldsGrouping() ，具有相同值的输入字段将转到螺栓的相同任务。是否有可能在输入过程中获取输入字段的值 prepare() 或之前 execute() ?实际上，我想为任务分配一个唯一的id，不管相同的拓扑重新启动。
fieldsGrouping()
prepare()
execute()
798qvoo81#
如果知道哪些任务处理哪些值对您来说很重要，那么您可以查看定向流，对于定向流，您不仅要发出元组和流id，还要发出组件示例的任务id来处理元组。您基本上是自己实现字段分组。这需要做更多的工作，但至少您知道prepare（）中的值是什么，因为这是由您的逻辑决定的。
1条答案
按热度按时间798qvoo81#
如果知道哪些任务处理哪些值对您来说很重要，那么您可以查看定向流，对于定向流，您不仅要发出元组和流id，还要发出组件示例的任务id来处理元组。您基本上是自己实现字段分组。这需要做更多的工作，但至少您知道prepare（）中的值是什么，因为这是由您的逻辑决定的。