Flink SQL 自定义 format
Posted
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Flink SQL 自定义 format相关的知识，希望对你有一定的参考价值。
参考技术A 由于 kafka 中的 json 属于嵌套，又不想二次序列化再把它展开，故自定义 format。1.自定义 Factory 实现 DeserializationFormatFactory
2.自定义 DeserializationSchema 实现 DeserializationSchema
为了简单起见，我们自定义一个 NullFormat ，也就是无论 kafka 中的消息是什么都返回 null，相当于 kafka 中没有消息
自定义 Factory
自定义 DeserializationSchema
<h2 id="4">4.使用自定义 Format </h2>
'format' = 'null' Factory 的唯一标识
然后就可以直接执行了
以上是关于Flink SQL 自定义 format的主要内容，如果未能解决你的问题，请参考以下文章
Flink SQL 知其所以然（五） 自定义 protobuf format
Flink实战系列Flink SQL 写入 kafka 自定义分区策略