在窗口的定义之前,首先需要确定一个应用使用什么样的时间语义。Time时间戳和Watermark机制的大致工作原理,接下来我们将展示如何在代码层面设置时间戳并生成Watermark。下面的代码展示了使用Scala调用这两个方法抽取时间戳并生成Watermark。如果我们不想修改Source,也可以在Source之后,通过时间戳指定器(TimestampAssigner)来设置。
在窗口的定义之前,首先需要确定一个应用使用什么样的时间语义。Time时间戳和Watermark机制的大致工作原理,接下来我们将展示如何在代码层面设置时间戳并生成Watermark。下面的代码展示了使用Scala调用这两个方法抽取时间戳并生成Watermark。如果我们不想修改Source,也可以在Source之后,通过时间戳指定器(TimestampAssigner)来设置。