0 相关源码

掌握F 中三种常用的Time处理方式,掌握F 中滚动窗口以及滑动窗口的使用,了解F 中的watermark。

F 在流处理工程中支持不同的时间概念。

1 处理时间(Processing time)

执行相应算子操作的机器的系统时间.

当流程序在处理时间运行时,所有基于时间的 算子操作(如时间窗口)将使用运行相应算子的机器的系统时钟。每小时处理时间窗口将包括在系统时钟指示整个小时之间到达特定算子的所有记录。

例如,如果应用程序在上午9:15开始运行,则第一个每小时处理时间窗口将包括在上午9:15到上午10:00之间处理的事件,下一个窗口将包括在上午10:00到11:00之间处理的事件

处理时间是最简单的时间概念,不需要流和机器之间的协调

它提供最佳性能和最低延迟。但是,在分布式和异步环境中,处理时间不提供确定

收藏 打印