问SCDF中两种不同流之间的通信
EN

Stack Overflow用户

提问于 2017-10-27 06:33:57

回答 1查看 155关注 0票数 1

我不知道这是否可能。我有一个场景，其中我有一个Stream，其中包含了一个源\处理程序\接收器。效果很好。现在，我需要创建另一个流，它将包含相同的结构，比如"source processor接收器“。根据业务需求，我需要执行一个任务，在这个任务中，两个流将相互通信。

例如，.MyStream-1接收器将把一个列表传递给Stream-2源.然后它就会操纵这个列表。

为什么第二次蒸汽:需求是创建第二个流，就像一个实用工具一样，任何其他流也可以访问它并获得所需的输出。

如果可能的话，请告诉我。提前谢谢。

发布于 2017-10-29 23:28:19

如果我要重新表述需求，那么您似乎想要共享从主管道到另一个流的数据。

流是一个无界的数据处理管道。在SCDF中使用水龙头可以潜在地满足这样的要求，即与流-2共享流-1在飞行中的数据副本。

根据位置(无论是在source还是processor)，您可以从指定的目的地(主题/队列)点击，并将相同的数据复制到辅助管道中，用于任何下游处理。

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/46968830

复制

相似问题

问SCDF中两种不同流之间的通信EN