首页
学习
活动
专区
圈层
工具
发布

Flink时间语义:Event Time、Processing Time和Ingestion Time

Event Time:事件的"真相"EventTime是指事件实际发生的时间,通常由事件自身携带的时间戳表示。例如,一个用户点击事件可能包含点击发生的确切时间戳clickTime。...Processing Time:简单但不够精确与EventTime不同,ProcessingTime是指事件被Flink处理系统处理的时间,即系统处理该事件的机器的系统时间。...Ingestion Time:系统摄入的"快照"IngestionTime是Flink提供的第三种时间语义,表示事件进入Flink系统的时间。...IngestionTime会自动生成Watermark,默认延迟为processing time的1毫秒,这使得它比ProcessingTime更稳定,但无法像EventTime那样精确处理乱序事件。...三种时间语义的深度对比特性Event TimeProcessing TimeIngestion Time时间来源事件自带时间戳系统处理时间source摄入时间结果准确性高(与处理速度无关)低(依赖处理速度

15720
  • 您找到你想要的搜索结果了吗?
    是的
    没有找到

    time模块

    time.sleep(sec):计时器函数,让工作暂停 time.time():返回当前时间的时间戳,计算自1970.1.1到现在的时间差(通常叫做纪元,是不同系统之间最简单的交换日期和时间的方法)。...time.ctime():将纪元值转化为字符串(“Mon Feb 3 22:31:03 2014”) time.localtime():默认返回一个struct_time,也可将一个时间参数传入该函数返回出对应的...struct_time time.mktime():把stuct_time转化为纪元值(struct_time只能精确到秒) time.strftime(format, [t]): 把一个struct_time...支持的符号表如下: 图片 import time nowtime=time.time() print("today",nowtime) str1=time.strftime("今天是%Y年%m月的第%d...天",time.localtime()) print(str1) #测试计时器函数 print("这是一个计时器函数,请闭上眼睛数五秒") time.sleep(5) print("You can go

    62720
    领券