Flink是否提供了一些API来获取会话窗口中的活动数据？
我做了一个Flink的会话窗口来跟踪访问者在我的网站上的网址。从不活动开始5分钟后结束（会话间隙）
Flink是否支持一些API来读取活动窗口中的数据，而无需逐个会话完成？
共有1个答案
Flink的数据流中的窗口非常灵活。例如，您可以定义一个自定义的触发器，该触发器在将记录添加到窗口时或在某个持续时间后（例如每分钟）发出更新的结果。如果您实现了发出早期结果的触发器，则需要实现下游运算符或逻辑，以便它能够处理更新的结果。
如果您使用事件时会话窗口，您应该注意会话窗口可能会被合并，即，根据会话间隙和记录中时间戳的最大异常情况，当接收到下降的记录时，两个会话窗口可能会被合并介于两者之间，并“连接”它们。在这种情况下，检测更新的逻辑需要更复杂一点。
-
我有一个由两个字段“键控”的记录流，然后分配一个间隔为30秒的会话窗口。我使用附加在记录上的“时间戳”作为事件时间。我正在使用“Assign AscendingTimeStamps”水印。 以下面的记录为例。该流由（用户,place）键控。 Record1:user1,place1,timestamp t1 Record2:user2，place1，timestamp在t1之后30秒 桶1 Rec
-
问题内容： 我正在尝试获取活动窗口的标题。该应用程序是一个后台任务，因此如果用户打开Eclipse，该函数将返回“ Eclipse- blabla”，因此它不会获取我自己窗口的窗口标题。我正在使用PyQt4在Python 2.6中进行开发。 我当前的解决方案是从SO的旧答案中借用并稍作修改的，看起来像这样： 它适用于大多数窗口，但不是全部。例如，它找不到我的kopete聊天窗口，或者找不到我当前正
-
如何获得XPage中活动会话的数量。我试图使用托管bean，但它只是返回一个奇怪的字符串。下面是简单的代码： 这是我从这里得到的。但是当我调用时，它只返回0（无论是否有人登录）。 如果你有时间，你可以在这里查看我的测试数据库。 请帮帮我.多谢！
-
我尝试使用flink sql窗口API:https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/table_api.html#group-windows
-
我有两个流，希望将第二个流连接到窗口内的第一个流，因为我需要对与会话相关的两个流的连接进行一些计算（流的连接控制会话）。 实际上，当从留档读取时，（会话）窗口只允许在单个流上进行计算，而不允许在连接中进行计算。 我曾尝试使用会话窗口和协处理器函数的组合，但结果并不完全符合我的预期。 有没有办法合并Flink中与会话窗口相关的两个流？
-
问题内容： 我试图用Java升级我的应用程序，使其仅在具有特定名称的进程窗口处于活动状态时才能工作。我发现使用JNI可以做到这一点，但是我不知道该怎么做。我只是找不到任何可以解释它的描述或示例。我的问题是- 如何获取Windows中当前活动窗口的进程名称（通过JNI或其他方式-我接受任何其他解决方案）？ 问题答案： 减轻您的痛苦，并使用JNA。您将需要下载 Win32 API的 jna.jar 和