概述
描述
Flink支持非常完善的数据类型，数据类型的描述信息都是由TypeInformation定义。TypeInformation主要作用是为了再Flink系统内有效的对数据结构类型进行管理，能够在分布式计算过程中对数据的数据类型进行管理和推断。同时基于对数据的类型信息管理，Flink内部对数据存储也进行了响应的性能优化。
1. 原生数据类型
1.java原生基本类型（装箱）或String类型
2.java原生基本类型（装箱）或String类型对象的数组
2. Java Tuples类型
目前支持的类型字段上限是25，如果字段数量超过上限，可以通过继承Tuple类的方式进行拓展
3. Scala Case Class类型
包括Scala tuples类型，支持的字段上限是22
4. POJOs类型
5. Flink Value类型
Value数据类型实现了Value，其中包括read()和write()两个方法完成序列化和反序列化操作，相对于通用的序列化工具会有比较高效的性能。目前Flink提供了内建的Value类型有IntValue、DoubleValue已经StringValue等，用户可以结合原生数据类型和Value类型使用
6. 特殊数据类型
最后
以上就是动听小蜜蜂为你收集整理的Flink-数据类型描述的全部内容，希望文章能够帮你解决Flink-数据类型描述所遇到的程序开发问题。
如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。
本图文内容来源于网友提供，作为学习参考使用，或来自网络收集整理，版权属于原作者所有。
发表评论 取消回复