ApacheBeam全局组合操作没有输出结果
创始人
2024-09-05 11:30:44
0次

首先,需要确保在组合操作中正确使用了全局窗口。如果窗口设置正确,则可能是因为元素没有在指定时间内发出而导致组合不输出结果。可以通过更改Watermark策略或增加等待时间来解决此问题。

以下是一个简单的实例,展示如何将两个PCollection组合,将其键值对中的值相加,并使用全局窗口输出结果:

PCollection> input = ...;
PCollection> output = input.apply(Combine.globally(new SumIntegersFn())
        .withFanout(10)
        .withTimestampCombiner(TimestampCombiner.END_OF_WINDOW)
        .withWindow(GlobalWindow.INSTANCE));

在这里,我们使用了Combine.globally方法来创建一个全局组合操作,然后将其与SumIntegersFn组合函数一起使用。withFanout参数是必需的,用于控制并发度。withTimestampCombiner参数设置元素时间戳合并策略,此处使用TimestampCombiner.END_OF_WINDOW,这意味着时间戳将被合并为窗口期结束时间。最后,我们将全局窗口应用于PCollection,以便在整个数据集上执行组合。

在以上示例中,我们使用全局窗口来保证组合操作获得所有数据。组合结果将在窗口结束时一次性输出。如果组合操作未输出结果,则可以适当调整窗口大小或等待时间来解决问题。

相关内容

热门资讯

每日必看教程开挂攻略!指尖四川... 每日必看教程开挂攻略!指尖四川麻将多功能开挂攻略,指尖四川麻将切实真的是有开挂攻略1、指尖四川麻将辅...
实测必看作弊器技巧!梦黄麻将多... 实测必看作弊器技巧!梦黄麻将多功能作弊器技巧,梦黄麻将果然存在有作弊器技巧1、梦黄麻将免费脚本咨询教...
研究成果辅助器教程!小白大作战... 研究成果辅助器教程!小白大作战多功能辅助器教程,小白大作战确实真的有辅助器教程所有人都在同一条线上,...
分享认知辅助软件!小闲巴渝棋牌... 分享认知辅助软件!小闲巴渝棋牌多功能辅助软件,小闲巴渝棋牌竟然是有辅助软件1、不需要AI权限,帮助你...
分享认知透视器app!温岭逸趣... 分享认知透视器app!温岭逸趣麻将多功能透视器app,温岭逸趣麻将真是是有透视器app1)温岭逸趣麻...
专业讨论作弊器插件!欢乐划水麻... 专业讨论作弊器插件!欢乐划水麻将多功能作弊器插件,欢乐划水麻将果然真的是有作弊器插件1、用户打开应用...
最新技巧外挂攻略!逍遥皖北棋牌... 最新技巧外挂攻略!逍遥皖北棋牌多功能外挂攻略,逍遥皖北棋牌都是存在有外挂攻略亲,关键说明,逍遥皖北棋...
今日公布辅助app!乐通多功能... 今日公布辅助app!乐通多功能辅助app,乐通一直有辅助app1、乐通破解器简单,乐通机器人操作,乐...
揭秘一下辅助攻略!青橙竞技多功... 揭秘一下辅助攻略!青橙竞技多功能辅助攻略,青橙竞技一贯真的是有辅助攻略1、玩家可以在青橙竞技线上大神...
推荐一款透视挂技巧!无锡麻将多... 推荐一款透视挂技巧!无锡麻将多功能透视挂技巧,无锡麻将原来有透视挂技巧1、起透看视 无锡麻将辅助软件...