通过 spark-SQL 获取 JSON 数据

Question

当我尝试使用 Spark-SQL 查询获取嵌套的 JSON 数据时：

SparkContext sc = new SparkContext(new SparkConf().setAppName("sql").setMaster("local"));
SQLContext  sqlContext = new SQLContext(sc);
DataFrame df = sqlContext.read().json("path_to_s3_bucket").cache();
df.registerTempTable("table_name");
DataFrame d=sqlContext.sql("Select address.state as state from table_name");

我得到以下异常

Exception in thread "main" org.apache.spark.sql.AnalysisException: Can't extract value from address

我的 Json 数据是这样的：-

"address":{"city":"xyz","state":"abc","country":"pqr"}

请帮助解决问题。

Answer 1

您的 json 无效。它应该是： {"address":{"city":"xyz","state":"abc","country":"pqr"}}