我有一个使用flink应用程序的场景，该应用程序接收以下格式的数据流：
{“event\u id”：“c1s2s34”，“event\u create\u timestamp”：“2019-03-07 11:11:23”，“amount”：“104.67”}
我使用下面的滚动窗口来查找过去60秒内输入流的总和、计数和平均值。
keyvalue.timewindow（时间.秒（60））
但是，如何标记聚合结果，以便我可以说16:20和16:21之间的输出数据流聚合结果是sum x、count y和average z。
任何帮助都是适当的。
1条答案
按热度按时间xfyts7mz1#
如果你看看Flink培训网站上的窗口示例——https://training.ververica.com/exercises/hourlytips.html --您将看到如何使用processwindowfunction从包含计时信息的窗口创建输出事件的示例，基本思想是，processwindowfunction上的process（）方法被传递一个上下文，该上下文又包含window对象，从中可以确定窗口的开始和结束时间，例如，
context.window().getEnd().然后，您可以安排processwindowfunction返回元组或POJO，其中包含要包含在报表中的所有信息。