Q1。考虑到我有一个数据帧df
和一个架构myschema
,我该如何继续以avro格式将该数据帧写入kafka主题?
第二季度。如果不考虑udf
,有什么优化的方法吗?
大多数可用的解决方案都适用于spark> 2.4,其中具有内置的avro功能供使用。
Q1。考虑到我有一个数据帧df
和一个架构myschema
,我该如何继续以avro格式将该数据帧写入kafka主题?
第二季度。如果不考虑udf
,有什么优化的方法吗?
大多数可用的解决方案都适用于spark> 2.4,其中具有内置的avro功能供使用。
大多数可用的解决方案适用于Spark> 2.4,其中具有内置的avro功能
该内置函数was an external library,但后来合并到主Spark项目中。如果您的