经过几周的运动分析工作，我有一大堆问题：
它有类似水印的东西吗？就像在Flink
正如我所说，即使是交错窗口也会根据实时情况发出：
记录按一分钟的交错窗口分组。当应用程序收到第一条amzn记录（行时间为11:00:20）时，stagger窗口开始。当1分钟的交错窗口过期时（11:00:20）{我想这可能是一个输入错误，应该是11:01:20}，结果在交错窗口内的记录（基于行时间和事件时间）被写入输出流。使用参差窗口，在一分钟窗口内具有行时间和事件时间的所有记录将在单个结果中发出。在这里拍摄
在关于滑动窗口的页面上，我找到了一些示例，在这里，您只能选择“partition by”字段，我可以假设窗口创建所基于的唯一字段是rowtime。
窗口w1 as（按“1”分钟前的间隔间隔”分隔）；
请不要认为这是仇恨的职位，我正在使用aws很多，大多数服务是可靠的和用户友好的。它更多的是试图指出更多用户（不仅仅是我）可能需要的一些特性。
或者，如果你知道这已经可以用于动觉分析，这将是有趣的知道，因为我没有发现任何有关这些功能的文档。
1条答案
按热度按时间rqcrx0a61#
从我在这里和这里的文档中读到的
对于基于时间的窗口查询，可以按时间指定窗口大小（例如，一分钟窗口）。这需要在in应用程序流中有一个单调递增的timestamp列(新行的时间戳大于或等于前一行。）amazon kinesis data analytics为应用程序流中的每个行提供了一个名为rowtime的时间戳列。指定基于时间的查询时，可以使用此列。对于您的应用程序，您可以选择其他时间戳选项。有关更多信息，请参阅timestamps和rowtime列。
可以有事件时间窗口，但时间戳必须单调递增，这表明只有简单的水印。对水印的搜索在此页上确实找到了一些点击。