flink Lateral
时间: 2023-11-07 16:17:11 浏览: 261
flink1.18.1安装包
Flink Lateral Join 是一种流处理的操作,它允许将两个数据流进行连接,其中一个数据流作为主流,另一个数据流作为侧输出流。Lateral Join 的特点是可以在主流中访问侧输出流的数据,这在某些场景下非常有用。
具体来说,Lateral Join 在主流中的每个事件上执行一次,然后将侧输出流中的所有事件与当前事件进行连接。这种连接是基于某种连接条件进行的,通常是根据事件中的某个字段进行匹配。连接成功后,可以将连接结果发送到下游处理算子或输出到外部系统。
Lateral Join 的一个典型应用场景是实时关联查询。例如,在一个在线电商平台中,我们可以将用户浏览记录作为主流,商品信息作为侧输出流,通过 Lateral Join 实时地将用户浏览记录与商品信息进行关联,从而实现个性化推荐、广告投放等功能。
总结来说,Flink Lateral Join 是一种强大的流处理操作,可以实现不同数据流的连接,并在主流中访问侧输出流的数据。它在实时关联查询等场景下具有广泛的应用价值。
阅读全文