from pyspark.sql.types import *
from pyspark.sql import SparkSession
spark = SparkSession.builder.appName('TEST').getOrCreate()sc=spark.sparkContextschema = StructType([
StructField(\"a\ StructField(\"b\ StructField(\"c\
# 通过定义好的dataframe的schema来创建空dataframe
df1 = spark.createDataFrame(spark.sparkContext.emptyRDD(), schema)df1.show()
想要创建⼀个空的spark dataframe,需要先指定schema 的类型
因篇幅问题不能全部显示,请点此查看更多更全内容