第一部分:
Flink 的数据类型
TypeInformation
Flink 的序列化过程
第二部分:
Flink 序列化的最佳实践
最常见的场景
实践–类型声明
-
对于非泛型类，直接传入 class 对象即可。
PojoTypeInfo<Person> typeInfo = (PojoTypeInfo<Person>) TypeInformation.of(Person.class);
-
对于泛型类，需要通过 TypeHint 来保存泛型类型信息。
final TypeInfomation<Tuple2<Integer,Integer>> resultType = TypeInformation.of(new TypeHint<Tuple2<Integer,Integer>>(){});
- 预定义常量。
- 自定义 TypeInfo 和 TypeInfoFactory。
实践–注册子类型
final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
Env. registerType(typeClass);
实践–Kryo 序列化
第三部分:
Flink 通信层的序列化:
