使用GroupByKey，每个键都在自己的窗口中
我有一个无界数据源（Kafka流）作为我的beam工作的输入。
数据的特性：
- 它们是元素组（组大小介于5-20个元素之间）。
- 每个组的键是唯一的标识符，并且仅用于该组。
- 组中第一个元素和最后一个元素之间的最大时间差小于2秒。
-
null
我的问题是：有没有一种方法可以让我在自己的窗口中分组每个键，并在一定时间后关闭它？非常感谢
共有1个答案
您可以尝试使用session窗口，其中每个会话都对应于输入数据集中的组。
-
我正在尝试设置一个Java程序，其中每个线程都可以使用自己的代理。 现在我只找到了一种全局设置代理的方法。(http://docs.oracle.com/javase/6/docs/technotes/guides/net/proxies.html) 如前所述，这些设置会影响使用这些选项调用的VM的整个生命周期内的所有http连接。然而，使用该系统是可能的。setProperty（）方法，使其具有
-
My Deck类在方法中创建一个52张牌副牌并返回一张5张牌手牌： 我的玩家类让我们提供关于玩家的信息。 问题是每个玩家都使用自己的套牌，因此有时两个或更多不同的玩家可能拥有同一张牌。我的问题是我如何设置我的程序让每个玩家使用同一套牌？多谢了。 姓名：无名氏，现金：500“黑桃之王，钻石之二，红心杰克，黑桃王牌，钻石之七”
-
问题内容： 目标是可以轻松访问任何级别的SwiftUI视图层次结构的托管窗口。目的可能有所不同- 关闭窗口，退出第一响应者，替换根视图或contentViewController。与UIKit / AppKit集成有时也需要通过窗口的路径，因此… 我在这里遇到和尝试过的 像这样的东西 或通过在每个SwiftUI视图中添加UIViewRepresentable / NSViewRepresentab
-
我正试图按照文档使用SpringCloudOpenFaign。我不想用尤里卡。我想在我的应用程序中配置服务器列表。yml。 如何包含FIGEN 如果您不想使用Eureka，您可以简单地在外部配置中配置服务器列表（参见上面的示例） 链接指向同一页。没有例子。 Ribbon处于维护模式，Spring建议将其关闭。通过这样做，将使用BlockingLoadBalancerClient。 就我而言，我有两
-
问题内容： 我正在开发python应用程序，我想获取每个打开的窗口。我需要窗口的名称和来过滤列表，以管理一些特定的窗口，移动它们并调整其大小。 我试图自己查看信息，但没有获得正确的代码。我尝试使用此代码，但仅获得每个窗口的标题（很棒），但我也需要。 这里有一个错误： 问题答案： 你混了和。 在你所得到的是通过获得，是一个对象。这就是为什么不接受它。你应该把它传给 如果要使用，则可以直接使用pyth
-
我正在使用LibGDX为android构建一个简单的游戏（基于flappy bird）。 当鸟（演员）移动时，它会在屏幕上保留旧图像，比如： 我不知道为什么会这样。。。 这是我的GameplayScreen类（代表游戏屏幕） 有人有线索吗？