闪烁中基于时间的系统事件触发器
当特定时间过去后，如何在Flink中设置触发器以执行某些操作？每天下午1点的流量总和
共有1个答案
KeyedProcessFunction可以使用计时器在特定时间触发操作（基于每个键）。它们可以是使用系统时间的处理时间计时器，也可以是由水印触发的事件时间计时器。
以下是文档中教程中的每个示例：
>
处理时间计时器
事件时间计时器
另请参阅有关流程功能和计时器的更详细文档。
请注意，如果您不想以键分区的方式应用计时器，而是需要对整个数据流进行操作（即，不并行），则可以使用keyBy（constant）进入键控上下文，而无需实际对流进行分区。
-
我正在运行一个简单的示例来测试基于EventTime的Windows。我能够生成带有处理时间的输出，但当我使用EventTime时，没有输出。请帮助我明白我做错了什么。
-
我正在阅读《Stream Processing with Apache Flink》一书，书中说：“从版本0.10.0开始，Kafka支持消息时间戳。当从Kafka版本0.10或更高版本读取时，如果应用程序以事件时间模式运行，使用者将自动提取消息时间戳作为事件时间戳*“因此在函数中，调用将默认返回Kafka消息时间戳？请提供一个简单的示例，说明如何实现AssignerWithPeriodicalW
-
我是Flink的新手，需要方法的帮助。我有时间颗粒度为5分钟的事件流。我想通过调用rest API来获取事件的元数据，其中包含过去1小时数据点的历史事件，即过去12点（5分钟时间颗粒度）。 e、 g事件的时间戳为10:00、10:05、10:10、10:15等，因此如果我想获取时间戳为11:00的事件元数据，我将调用send发送所有时间戳为10:00、10:05、10:10、10:15的事件。。1
-
我对Flink在事件时间上加水印时如何处理后期元素有些困惑。 现在我认识到这是一个微不足道的例子，但不理解这会使理解更复杂的流变得困难。
-
问题内容： 我试图每小时创建一个新的日志文件。我在RollingFileAppender中使用lo4j2的TimeBasedTriggerringPolicy。以下是我从log4j2官方站点获取的示例xml配置代码。 在时间间隔属性中，我设置了1表示1小时。但是我的文件仍然不会每1小时滚动一次。 请帮助我发现任何错误。 注意：我包括了log4j2的beta9（这是最新的） 问题答案： 这里的1表示
-
我正在尝试创建每小时的新日志文件。我正在RollingFileAppender中使用lo4j2的TimeBasedTriggerringPolicy。下面是我从log4j2官方站点获取的示例xml配置代码。 在interval属性中，我设置了1表示1小时。但我的文件并不是每隔1小时滚动一次。