Flink 1.7.2 業務時間戳分析流式數據源碼分析

Flink 1.7.2 業務時間戳分析流式數據源碼分析 源碼 https://github.com/opensourceteams/flink-maven-scala 概述 因爲Flink默認的ProcessTime是按Window收到Source發射過來的數據的時間，來算了，也就是按Flink程序接收的時間來進行計算，但實際業務，處理週期性的數據時，每5分鐘內的數據，每1個小時內的數據進行分析，

>>阅读原文<<