Flink之詳解InnerJoin、leftJoin以及窗口延遲時間的問題

文章目錄 以案例驅動對join的認知 1、前提： 2、數據源 一、StreamDataSourceA 二、StreamDataSourceB 3、InnerJoin（只保留能join上的）代碼 一、加載數據源 二、對兩個數據設置WaterMark 三、作InnerJoin操做 4、LeftJoin代碼 一、獲取兩個輸入流 二、抽取timeStamp 設定waterMark 三、作left join

>>阅读原文<<