Apache Storm的MinBy不返回任何结果。
创始人
2024-09-04 23:01:09
0

如果Apache Storm的MinBy操作没有返回任何结果,可能是由于以下几个原因:

  1. 没有正确设置Bolt的输出字段:确保在Bolt中正确设置了输出字段,以便在MinBy操作中使用。
// 在Bolt的declareOutputFields方法中设置输出字段
public void declareOutputFields(OutputFieldsDeclarer declarer) {
    declarer.declare(new Fields("field1", "field2")); // 设置输出字段
}
  1. 没有正确设置Bolt的输出流ID:确保在Bolt中正确设置了输出流ID,以便在MinBy操作中引用。
// 在Bolt的execute方法中发射输出流
collector.emit("stream1", new Values(value1, value2)); // 发射带有流ID的输出流
  1. 没有正确设置Topology的MinBy操作:确保在Topology的MinBy操作中正确指定了输入流ID和输出流ID。
// 在Topology中设置MinBy操作
topologyBuilder.setBolt("minByBolt", new MinByBolt())
    .shuffleGrouping("spoutBolt", "stream1") // 指定输入流ID
    .shuffleGrouping("previousBolt", "stream2"); // 指定另一个输入流ID
topologyBuilder.setBolt("outputBolt", new OutputBolt())
    .shuffleGrouping("minByBolt", "stream1"); // 指定输出流ID

确保在以上步骤中都正确设置了字段、流ID和流分组方式,以便在MinBy操作中正确地处理和返回结果。

相关内容

热门资讯

透视好牌(cloudpoker... 透视好牌(cloudpoker辅助透视)外挂透明挂辅助APP(透视)软件透明挂(2024已更新)(哔...
八分钟了解(来玩app德州)外... 您好,来玩app德州这款游戏可以开挂的,确实是有挂的,需要了解加微【285696317】很多玩家在这...
大神推荐(aapoker规律)... 大神推荐(aapoker规律)外挂透明挂辅助脚本(透视)发牌规律(有挂透视)-哔哩哔哩;aapoke...
热点推荐!约局吧软件有辅助(透... 热点推荐!约局吧软件有辅助(透视)辅助透视(有挂规律)-哔哩哔哩1、点击下载安装,微扑克wpk插件透...
最新技巧(云扑克德州PK)外挂... 最新技巧(云扑克德州PK)外挂透明挂辅助脚本(透视)透视辅助(2024已更新)(哔哩哔哩);科技详细...
透明黑科技(wEpoke)外挂... 透明黑科技(wEpoke)外挂透明挂辅助挂(辅助挂)其实真的有挂(2024新版)(哔哩哔哩);大神普...
分享开挂内幕(德扑自定义)外挂... 分享开挂内幕(德扑自定义)外挂透明挂辅助机制(透视)发牌规律(有挂方法)-哔哩哔哩;玩家必备必赢加哟...
重大推荐!德扑之星窥牌(透视)... 《德扑之星窥牌软件透明挂》是一款多人竞技的德扑之星窥牌辅助透视游戏,你将微扑克对手来到同一个战场,为...
每日必看教程(德扑数据)外挂透... 每日必看教程(德扑数据)外挂透明挂辅助器安装(辅助挂)透视辅助(2021已更新)(哔哩哔哩);科技安...
两分钟了解(pokerworl... 这是一款非常优秀的pokerworld软件 ia辅助检测软件,能够让你了解到pokerworld软件...