Apache-beam在分组后的窗口处理中无法触发groupbykey操作。
创始人
2024-09-05 03:00:46
0

这可能是由于窗口在窗口范围内没有足够的数据触发groupbykey操作。可以尝试设置Watermark和窗口持续时间以确保Beam可以在窗口拆分时正确触发数据组合。 例如,在以下代码示例中,我们将使用10秒的窗口和1秒的水印,并将在窗口结束时触发组合操作:

p.apply("Read data from source", ReadFromPubSub(subscription=subscription))
 .apply("Extract timestamp", WithTimestamps(lambda _: int(time.time())))
 .apply("Add key and value", Map(lambda x: (x['key'], x['value'])))
 .apply("Window into fixed intervals", WindowInto(FixedWindows(10)))
 .apply("Add watermark", WithTimestamps(lambda x: x[1]-1))
 .apply("Group by key", GroupByKey())
 .apply("Do something with groups", ...))

在这个例子中,使用WithTimestamps将事件的时间戳设置为当前时间,然后使用FixedWindows将数据窗口化为10秒大小的窗口。接下来,使用AddTimestamps将每个事件的水印设置为事件时间戳减1秒,以便Beam可以在10秒窗口结束时触发groupbykey操作。最后,使用GroupByKey将数据按键分组,并对组执行某些操作。

重要提示:确保时间戳使用相同的时间单位(例如秒或毫秒),以避免可能的错误。

相关内容

热门资讯

重大通报!Wepoke德州版本... 重大通报!Wepoke德州版本(wePokE)外挂透明挂辅助软件(透视)安装教程(讲解有挂)-哔哩哔...
透视代打(微扑克ai代打)外挂... 透视代打(微扑克ai代打)外挂透明挂辅助器安装(辅助挂)软件透明挂(2021已更新)(哔哩哔哩);科...
透明新版(云扑克辅助挂)外挂透... 云扑克辅助挂赢率提升策略‌;透明新版(云扑克辅助挂)外挂透明挂辅助APP(透视)发牌规律(有挂方式)...
透视了解!德州最新(WEPOk... WePoke高级策略深度解析‌;透视了解!德州最新(WEPOke)外挂透明挂辅助APP(辅助挂)教你...
透视好牌(aapOKER)外挂... 透视好牌(aapOKER)外挂透明挂辅助APP(透视)透视辅助(2025已更新)(哔哩哔哩)是一款可...
分享一款(微扑克游戏)外挂透明... 分享一款(微扑克游戏)外挂透明挂辅助器(辅助挂)发牌规律(了解有挂)-哔哩哔哩是一款可以让一直输的玩...
程序员教你!pokerrrr开... WePoker透视辅助版本解析‌,程序员教你!pokerrrr开挂(wepoke)外挂透明挂辅助机制...
透视透明(德州之星ai)外挂透... 1、透视透明(德州之星ai)外挂透明挂辅助工具(辅助挂)透视辅助(2021已更新)(哔哩哔哩);该软...
热点推荐(Wepoke代打)外... 热点推荐(Wepoke代打)外挂透明挂辅助软件(透视)透视辅助(有挂分享)-哔哩哔哩;值得一提的是,...
必知教程!微扑克总结(Wepo... 必知教程!微扑克总结(Wepoke)外挂透明挂辅助app(辅助挂)可靠技巧(真实有挂)-哔哩哔哩;微...