开发者社区> 问答> 正文

GenericRowData与BinaryRowData的转换

我看Kafka Connector源码生成的是GenericRowData,到Jdbc Sink类型编程BinaryRowData了。Runtime层把GenericRowData转换BinaryRowData的规则是什么?*来自志愿者整理的flink

展开
收起
雪哥哥 2021-12-05 12:16:47 1829 0
1 条回答
写回答
取消 提交回答
  • GenericRowData和BinaryRowData都是RowData这个接口的具体实现。 所以你只需要针对RowData进行编程即可,不能假设它使用哪个具体实现。

    关于你的问题,在算子之间数据计算和转换的时候,会有很多地方构造出来BinaryRowData, 比如典型的就是序列化的时候都会按照BinaryRowData来序列化。希望对你有所帮助。*来自志愿者整理的flink

    2021-12-05 17:46:23
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
低代码开发师(初级)实战教程 立即下载
冬季实战营第三期:MySQL数据库进阶实战 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载