2016-12-22 3 views

ответ

1

Firsly должен создать dataframe

peopleDF = spark.read.json(your/file/path/) 

После этого создать виртуальную таблицу или представление

peopleDF .createOrReplaceTempView("mytable") 
queryResult= spark.sql("SELECT name FROM test) 
Смежные вопросы