搜索
您的当前位置:首页正文

创建一个空的sparkdataframe

来源:爱够旅游网
创建⼀个空的sparkdataframe

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 的类型

因篇幅问题不能全部显示,请点此查看更多更全内容

Top