首页 > 技术文章 > Flink时间概念

gouhaiping 2019-12-13 14:33 原文

API见org.apache.flink.streaming.api.TimeCharacteristic

分别是event time(事件时间:事件发生时的时间),ingestion time(摄取时间:事件进入流处理系统的时间),processing time(处理时间:消息被计算处理的时间)

用法为在流执行环境时设置,例子如下

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.setStreamTimeCharacteristic(TimeCharacteristic.ProcessingTime);

推荐阅读