我不明白如何在Apache Storm中拆分流.例如,我有一个螺栓A,经过一些计算后有somevalue1,somevalue2和somevalue3.它想将somevalue1发送到bolt B,somevalue2发送到bolt C,somevalue1,somevalue2发送到bolt D.如何在Storm中执行此操作?我将使用什么分组以及拓扑结构会是什么样的?预先感谢您的帮助.
我有一个看起来像下面粘贴的JSON.我试图提取每个单独的记录并将其推送到队列中.我如何提取骡子中的每条记录?我一直在尝试使用集合拆分器和foreach循环,但我无法弄清楚如何让它工作.
{
"locations": {
"record": [
{
"id": 8817,
"loc": "NEW YORK CITY"
},
{
"id": 2873,
"loc": "UNITED STATES"
},
{
"id": 1501,
"loc": "NEW YORK STATE"
}
]
}
}
Run Code Online (Sandbox Code Playgroud)