gpt4 book ai didi

java - Apache Storm bolt 从不同的 spout/bolt 接收多个输入元组

转载 作者:搜寻专家 更新时间:2023-11-01 01:42:13 34 4
gpt4 key购买 nike

bolt 是否可以从不同的 spout/bolt 接收多个输入元组?例如,Bolt C 接收来自 Spout A 的输入元组和来自 Bolt B 的输入元组以进行处理。我应该如何实现它?我的意思是为 Bolt C 及其拓扑编写 Java 代码。

最佳答案

教程回答了您的问题。

https://storm.apache.org/documentation/Tutorial.html

这是您的目标代码(教程中的 C/P):

builder.setBolt("exclaim2", new ExclamationBolt(), 5)
.shuffleGrouping("words")
.shuffleGrouping("exclaim1");

exclaim2 将接受来自 wordsexclaim1 的元组,它们都使用随机分组。

关于java - Apache Storm bolt 从不同的 spout/bolt 接收多个输入元组,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/30410661/

34 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com