从 dataframe 创建一个 SQL 表
可以使用 dataframe 创建一个临时表。 临时 表在会话结束后将不再存在。 Spark 文档也将这类表称为 SQL temporary view。 在文档中,这被称为将 dataframe 注册为一个 SQL 临时视图。 该命令直接在 dataframe 上调用:如果表不存在就创建;如果已存在,则用 dataframe 当前的数据替换它。
本练习是课程的一部分
Python 中的 Spark SQL 入门
练习说明
- 将文件
trainsched.txt中的 csv 数据读取为 dataframe,并存入名为df的变量。 - 由
df创建一个临时表。将该表命名为 "table1"。
交互式实操练习
通过完成这段示例代码来试试这个练习。
# Load trainsched.txt
df = spark.____.____("trainsched.txt", header=True)
# Create temporary table called table1
df.____(____)