Flink实战之自定义TableFormat

自定义TableFormat主要包含如下步骤：

  1. 实现TableFormatFactory接口

  2. 实现SerializationSchemaFactory、DeserializationSchemaFactory 序列化和反序列化接口

    两个工厂接口用于创建Schema的序（反）列化对象类。

  3. 实现SerializationSchema、DeserializationSchema

  4. 在source或sink Function的invoke方法中对数据使用SerializationSchema的serialize或DserializationSchema的deserialize方法对数据进行序列化和反序列化。

demo可参考https://github.com/zhuxiaoshang/flink-be-god/tree/master/flink-formats/flink-format-customized/src/main/java/format/customized
具体代码实现可以参考flink源码中的几种format。

©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成，浏览时请结合常识与多方信息审慎甄别。
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。

相关阅读更多精彩内容

友情链接更多精彩内容