У меня есть следующий код: -
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>