GenericRowData和BinaryRowData都是RowData这个接口的具体实现。 所以你只需要针对RowData进行编程即可，不能假设它使用哪个具体实现。
关于你的问题，在算子之间数据计算和转换的时候，会有很多地方构造出来BinaryRowData， 比如典型的就是序列化的时候都会按照BinaryRowData来序列化。 Luna Wong <[email protected]> 于2021年4月8日周四 下午7:36写道： > 我看Kafka Connector源码生成的是GenericRowData，到Jdbc > Sink类型编程BinaryRowData了。Runtime层把GenericRowData转换BinaryRowData的规则是什么？ > -- Best, Benchao Li
