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);

相关