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

一世独秀

 关注

阅读 123

2022-03-17

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

可以看到:

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

env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);

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

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

 

相关推荐

大数据_Flink_Java版_数据处理_时间语义(1)_时间语义概念---Flink工作笔记0049

you的日常 90 0 0

大数据_Flink_Java版_数据处理_时间语义(2)_时间语义的应用---Flink工作笔记0050

逸省 52 0 0

大数据_Flink_Java版_数据处理_事件时间语义下的窗口测试(1)---Flink工作笔记0057

秦瑟读书 81 0 0

大数据_Flink_Java版_数据处理_事件时间语义下的窗口测试(2)_迟到数据处理---Flink工作笔记0059

前端王祖蓝 63 0 0

大数据_Flink_Java版_Table API 和 Flink SQL(13)_事件时间特性---Flink工作笔记0093

灵魂跑者 52 0 0

大数据_Flink_Java版_Table API 和 Flink SQL(12)_处理时间特性---Flink工作笔记0092

紫荆峰 89 0 0

大数据_Flink_Java版_数据处理_Watermark(7)_的设定原则---Flink工作笔记0056

小月亮06 101 0 0

大数据_Flink_Java版_数据处理_Watermark(7)在代码中的设置---Flink工作笔记0055

杰克逊爱学习 98 0 0

大数据_Flink_Java版_数据处理_Window_API(3)_计数窗口测试---Flink工作笔记0048

ZSACH 57 0 0

大数据_Flink_Java版_数据处理_Watermark_概念和原理---Flink工作笔记0052

追梦人的自留地 83 0 0

精彩评论（0）

0 0 举报