首页 > TAG信息列表 > TypeInformation
5分钟快速掌握Flink类型与序列化
本篇要解决的问题： Flink是使用Java的序列化方式吗？ Java序列化方式有什么问题？ Java中是用Class描述类型，Flink也是用Class描述吗？ 请解释以下Java类型擦除。 Flink中为什么使用Lambda表达式实现flatMap需要通过returns指定类型呢？ new ArrayList()和new ArrayList(){}的区别是什么？Apache Flink 进阶（五）：数据类型和序列化
Apache Flink 进阶（五）：数据类型和序列化 马庆祥 Flink 中文社区 本文根据 Apache Flink 系列直播整理而成，由 Apache Flink Contributor、奇虎360数据开发高级工程师马庆祥老师分享。文章主要从如何为 Flink 量身定制序列化框架、Flink 序列化的最佳实践、Flink 通信层的序列化以及【源码】Flink 三层图结构——StreamGraph 生成前准备 Transformation
最近一直在看 StreamGraph 生成的源码，刚好有点思路，准备动手了发现，如果不说下 Transformation 后面的 StreamGraph 会差比较多意思，所以先做点铺垫。 ## Transformation Transformation 类是 Flink 转换算子的基类，实现类有下面这些 AbstractMultipleInputTransformation CoFeedback