同步几个喷口和螺栓在苍鹭

Question

我正在使用Heropy。我的拓扑结构看起来更像：

喷口1->；螺栓1->；螺栓2

喷口2----------gt；螺栓2

因此，Bolt2需要来自Spout2和Bolt1的信息才能发出结果，但是来自Spout2的信息比来自Bolt1和Bolt2的信息来得快，Bolt2必须等待，直到if同时具有Spout2和Bolt1信息。如何使用Heron API同步信息流，使Bolt2仅在所有可用信息之后才发出结果

Answer 1

通常，在流媒体中不能保证顺序/同步。我觉得，对喷注1和喷注2自己来说，100%同步是很难的

我认为有一个选项可以考虑：将bolt1挂接到spout2，直接从spout2发出元组，将bolt2从spout2断开。因此，bolt1成为排序真理的来源

窗口可能是另一种选择，但它需要更多的考虑和工作

Answer 2

Heron不会自动同步来自不同组件的元组。因此，您需要缓冲来自Spout2的元组，并等待来自Bolt1的对应元组到达，然后进行计算