首先需要确认是否已经在Spark SQL中创建了名为test_result的表。如果没有创建,则需要先创建该表,例如:
from pyspark.sql.types import *
schema = StructType([
StructField("id", IntegerType(), True),
StructField("name", StringType(), True),
StructField("age", IntegerType(), True)
])
data = [
(1, "Tom", 25),
(2, "Jerry", 30),
(3, "Alice", 20)
]
df = spark.createDataFrame(data, schema)
df.write.mode("overwrite").saveAsTable("test_result")
如果已经创建了表test_result,则需要检查表名是否拼写正确,并确认是否在当前的SparkSession中注册了该表,例如:
df = spark.table("test_result")
如果仍然出现该异常,则有可能是因为该表不在当前的默认数据库中,需要指定该表所在的数据库,例如:
df = spark.table("database.test_result")
其中,database为该表所在的数据库名称。
下一篇:标题/部分固定在页面顶部