Flink框架源码——数据类型数据类型管理TypeInformation
目录数据类型管理TypeInformation数据类型:类型推断主动声明类型数据类型管理Flink框架内部是自主进行内存管理的,其实现大量使用堆外内存,对开发者隐藏无论类型与逻辑类型的转换细节,Flink自己实现了一套TypeInformation,用于推断与转换数据类型,实现serializers以及comparators。但在某些情况下却无法直接做到,例如定义函数时如果使用到了泛型,JVM就会出现类型擦除的问题,使得Flink并不能很容易地获取到数据集中的数据类型信.