Flink 流处理中获取当前处理时间戳：`val now_timestamp = context.timerService().currentProcessingTime()` 解释

本文将解释代码片段 'val now_timestamp = context.timerService().currentProcessingTime()' 在 Flink 流处理应用程序中的作用。

这行代码的作用是在 Flink 流处理应用程序中获取当前的处理时间戳，并将其赋值给 'now_timestamp' 变量。

具体解释如下：

1. 'context'：这是 Flink 中的 'RuntimeContext' 对象，提供了访问运行时上下文的方法和信息。

2. 'timerService()'：'RuntimeContext' 对象中的 'timerService()' 方法用于获取一个 'TimerService' 对象，它用于注册和管理定时器。

3. 'currentProcessingTime()'：'TimerService' 对象的 'currentProcessingTime()' 方法用于获取当前的处理时间戳。处理时间是 Flink 应用程序自身维护的一个逻辑时钟，可以用来实现基于时间的操作，如定时器触发和时间窗口计算。

4. 'val now_timestamp = ...'：将获取到的当前处理时间戳赋值给 'now_timestamp' 变量，以便在后续的代码中使用。

因此，该行代码的目的是在 Flink 程序中获取当前的处理时间戳，并将其保存在 'now_timestamp' 变量中供后续使用。