我正试图使用以下文档向Kafka接收器写入内容:https://docs.databricks.com/spark/latest/structured-streaming/avro-dataframe.html#example-使用架构注册表
但是,我在spark avro中找不到包含多个参数的函数(https://mvnrepository.com/artifact/org.apache.spark/spark-avro_2.11). 有人知道它是否已被移动/重命名,或者我应该使用另一个库吗?谢谢您!
1条答案
按热度按时间cbeh67ev1#
在
spark 3.0
,这些函数已移动到org.apache.spark.sql.avro.functions.scala
对象检查这个-spark repo jira-spark-26870
另外,您所指的databricks文档也是基于
spark 3