flink双流join
时间: 2023-09-14 15:15:17 浏览: 93
flink流批一体存储
Flink双流join是指将两个数据流(stream)联合起来,以实现一些特定的数据操作。双流join有两种方式:基于事件时间(Event Time)和基于处理时间(Processing Time)。
基于事件时间的双流join:
在基于事件时间的双流join中,数据流是按照事件发生的时间排序的。具体地说,Flink首先从每个数据流中提取事件时间戳,并将它们合并成一个全局的事件时间戳。然后,Flink将两个数据流根据事件时间戳进行联合,即在事件时间戳相同的情况下,将两个事件合并在一起,形成一个新的事件。
基于处理时间的双流join:
在基于处理时间的双流join中,数据流是按照处理时间排序的。具体地说,Flink将两个数据流根据它们到达Flink系统的时间进行联合,即在处理时间相同的情况下,将两个事件合并在一起,形成一个新的事件。
总之,双流join是Flink中非常常见的数据操作之一,它可以帮助我们实现很多有趣的功能,如实时计算、实时数据分析等。
阅读全文