Flink系列：事件Time時間分類（指定事件時間）

時間分類

Stream資料中的Time（時間〉有下面3種：

• Event Time

事件産生的時間

• Ingestion Time

事件

進入Flink的時間

• Processing Time

被處理時目前系統的時間

流轉圖 

指定Stream資料中的Time

/預設是處理時間為基礎，可以修改：

env.setStreamTimeCharacteristic(TimeCharacteristic.ProcessingTime); //預設 env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime); env.setStreamTimeCharacteristic(TimeCharacteristic.IngestionTime);

相關