Flink之详解InnerJoin、leftJoin以及窗口延迟时间的问题

文章目录 以案例驱动对join的认知 1、前提： 2、数据源 一、StreamDataSourceA 二、StreamDataSourceB 3、InnerJoin（只保留能join上的）代码 一、加载数据源 二、对两个数据设置WaterMark 三、作InnerJoin操做 4、LeftJoin代码 一、获取两个输入流 二、抽取timeStamp 设定waterMark 三、作left join

>>阅读原文<<