ApacheBeam中的FixedWindow在GroupByKey转换后没有作用
创始人
2024-09-05 12:30:13
0次

这个问题通常是由于没有正确使用窗口引起的。通常需要在GroupByKey之前使用window操作来指定窗口。以下是一个示例，使用了FixedWindow来解决这个问题：

import apache_beam as beam

with beam.Pipeline() as p:
    (p | beam.Create([("A", 1), ("B", 2), ("A", 3), ("B", 4)])
       | beam.WindowInto(beam.window.FixedWindows(2))
       | beam.GroupByKey()
       | beam.Map(print))

在这个例子中，我们使用了FixedWindows操作来定义一个大小为2的窗口。这意味着所有具有相同键的输入元素将被分配到同一个窗口中。然后，我们可以在窗口中执行任何操作，例如GroupByKey和Map等。

上一篇：ApacheBeam中Deduplicate函数出现问题

下一篇：apachebeam中的固定窗口从什么时候开始？

相关内容

热门资讯

近年来!开心游戏攻略!果然真的... 近年来!开心游戏攻略!果然真的是有辅助平台(有挂头条)-哔哩哔哩1）开心游戏攻略有没有挂：进一步探索...
最新消息!川娱竞技辅助插件!真... 最新消息!川娱竞技辅助插件!真是真的有辅助插件(有挂教学)-哔哩哔哩在进入川娱竞技辅助插件软件靠谱后...
经调查!德普之星辅助器!其实是... 经调查!德普之星辅助器!其实是有辅助修改器(有挂讲解)-哔哩哔哩1、这是跨平台的德普之星辅助器轻量版...
连日来!衡阳丫丫辅助!原来真的... 连日来!衡阳丫丫辅助!原来真的有辅助脚本(有挂详情)-哔哩哔哩1、完成衡阳丫丫辅助辅助器v3.3的残...
针对!都莱软件安装辅助!一直是... 针对!都莱软件安装辅助!一直是有辅助安装(有挂细节)-哔哩哔哩都莱软件安装辅助脚本下载中分为三种模型...
近年来!激k辅助器是真的吗!确... 近年来!激k辅助器是真的吗!确实真的是有辅助脚本(确实有挂)-哔哩哔哩1、很好的工具软件，可以解锁游...
据文件显示!粤友会辅助器下载教... 据文件显示!粤友会辅助器下载教程!一贯真的是有辅助安装(有挂解惑)-哔哩哔哩1、任何粤友会辅助器下载...
据悉!开心泉州小程序辅助哪里查... 据悉!开心泉州小程序辅助哪里查看!果然有挂辅助脚本(有挂解密)-哔哩哔哩1、开心泉州小程序辅助哪里查...
今日!随意玩最新跳转链接有辅助... 今日!随意玩最新跳转链接有辅助吗!原来真的是有辅助app(有挂实锤)-哔哩哔哩随意玩最新跳转链接有辅...
现有说明如下!皮皮跑子胡子修改... 现有说明如下!皮皮跑子胡子修改器!切实有挂辅助修改器(果真有挂)-哔哩哔哩1、皮皮跑子胡子修改器免费...