Flink 源码解读系列 DataStream 数据流元素 StreamElement

Posted @SmartSi

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Flink 源码解读系列 DataStream 数据流元素 StreamElement相关的知识,希望对你有一定的参考价值。

传送门:Flink 系统性学习笔记


Flink版本:1.13.5

Flink 中使用 StreamElement 来表示数据流元素:

public abstract class StreamElement 
   
    // 是否是 Watermark
    public final boolean isWatermark() 
   
        return getClass

以上是关于Flink 源码解读系列 DataStream 数据流元素 StreamElement的主要内容,如果未能解决你的问题,请参考以下文章

Flink 源码解读

Flink 源码解读系列 DataStream 数据流元素 StreamElement

Flink 源码解读系列 DataStream 数据流元素 StreamElement

Flink 源码解读系列 DataStream 窗口分配器 WinowAssigner

Flink 源码解读系列 DataStream 窗口分配器 WinowAssigner

Flink 源码解读系列 DataStream 时间服务管理器 TimeServiceManager 设计与实现