scala - from_json 不是对象 org.apache.spark.sql.functions 的成员

Question

我有以下代码：-

import org.apache.spark.sql.functions.from_json
val ds = df.select(from_json($"value" cast "string", schema)).as[event]

但它给出了一个错误

value from_json is not a member of object org.apache.spark.sql.functions 

使用此依赖项：-

<dependency>
        <groupId>org.apache.spark</groupId>
        <artifactId>spark-sql_2.11</artifactId>
        <version>2.0.0</version>
</dependency>

标签： scalaapache-sparkdataframeapache-spark-sqlspark-streaming