阿帕奇风暴TICK元组在Apache flink中相当于什么？

Question

我是apache Flink的新手。我想每小时记录缓存中条目的数量到一个文件。我使用tick元组在这个风暴中做了这个。 Flink有类似的东西，我可以在flink运营商中使用吗？

Answer 1

您可以使用ProcessFunction，它可以与处理时间和事件定时器一起使用。但我会说Flink的window operator是在时间有限的窗口中计数事物的最自然的方式。