慢慢 6 years ago
parent 03b1d1b662
commit bf69a24dfa

@ -78,7 +78,7 @@ df.select("name").show()
### 2.1.5 通过SQL语句的方式 ### 2.1.5 通过SQL语句的方式
```python ```python
#首先注册df为一个临时视图 #首先注册df为一个视图
df.createOrReplaceTempView("p") df.createOrReplaceTempView("p")
#通过spark.sql("SQL语句")执行SQL语句 #通过spark.sql("SQL语句")执行SQL语句
sqlDF = spark.sql("SELECT name FROM p") sqlDF = spark.sql("SELECT name FROM p")

Loading…
Cancel
Save