ApacheFlink类型及序列化研读&生产应用

见贤思齐

目录一、背景二、简单理论阐述(基于Flink 1.13)????1. 支持的数据类型????2. TypeInformation????3. 何时需要数据类型获取????4. 数据类型的自动推断三、开发实践????1.Flink代码作业????????1.1 如何显式指定数据类型????????1.2 自定义数据类型&自定义序列化器????????????1.2.1 POJO类????????????1.2.2 自定义TypeInformation????????????1.2.3 自定义TypeSerializer????2. Flink SQL自定义函数????????2.1 如何显式指定数据类型????????????2.1.1 指定accumulatorType????????????2.1.2 指定outputType????????????2.1.3 指定intputType????????????2.1.4 根据inputType动态调整outType???????????????????? 或者accumulatorType????????2.2 自定义DataType四、结语