pyspark建表语句

在 PySpark 中，可以使用 SparkSession 对象的 createDataFrame 方法来创建 DataFrame，并通过调用 createOrReplaceTempView 方法将 DataFrame 注册为临时表。下面是一个示例的建表语句：

from pyspark.sql import SparkSession

# 创建 SparkSession 对象
spark = SparkSession.builder \
    .appName("example") \
    .getOrCreate()

# 创建一个示例的 DataFrame
data = [("Alice", 25), ("Bob", 30), ("Charlie", 35)]
df = spark.createDataFrame(data, ["name", "age"])

# 注册临时表
df.createOrReplaceTempView("people")