【发布时间】:2017-07-29 06:43:28
【问题描述】:
我是 apache Flink 的新手。我想每小时将缓存中的条目数记录到文件中。我在风暴中使用滴答元组做到了这一点。 Flink 是否有类似的东西可以在 flink 运算符中使用?
【问题讨论】:
我是 apache Flink 的新手。我想每小时将缓存中的条目数记录到文件中。我在风暴中使用滴答元组做到了这一点。 Flink 是否有类似的东西可以在 flink 运算符中使用?
【问题讨论】:
您可以使用ProcessFunction,它可以与进程时间和事件时间计时器一起使用。但我想说 Flink 的 window operator 是在有时间限制的窗口中计算事物最自然的方式。
【讨论】: