开发者社区> 问答> 正文

flink解析复杂protobuf,注册成table遇到问题

学习flink 2018-12-11 15:27:46 957

目标:kafka protobuf--》row--》table--》sql--》hdfs。
问题:protobuf是嵌套结构,转成row时,制定type出现问题。
第一步:自定义反序列化方式,将protobuf转成row
_
第二步:for循环放入row
_Row
第三步:指定字段name和type时不生效
_name_type
因为protobuf有嵌套,所以此处用Types.POJO。这个用法是否问题?
type_POJO_

消息中间件 Kafka 流计算
分享到
取消 提交回答
全部回答(1)
+ 订阅

构建可靠、高效、易扩展的技术基石

推荐文章
相似问题
推荐课程