大数据_Flink_Java版_数据处理_时间语义(3)_事件时间语义的设置---Flink工作笔记0051

然后我们再来看,如何设置时间语义.

可以看到:

我们再设置环境以后,设置并行度,然后设置

env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);

这里设置了,时间语义采用,数据产生时间来算.

我们可以去看看这个TimeCharacteristic这个是个枚举类