【Flink】Flink时间是如何设计的

1.概述 flink中的时间是如何设置的呢? 1.1 主要的类 1.1.1 AbstractStreamOperator flink流中的核心类,所有流操作的基本抽象类,包含了一个operator的生命周期,里面有一个关于时间服务的manager的属性InternalTimeServiceManager 1.1.2 InternalTimeServiceManager flink 内部提供时间服务
相关文章
相关标签/搜索