โ06-07-2021 09:30 AM
from pyspark.sql.types import * schema = StructType([ StructField("c1", IntegerType(), True), StructField("c2", StringType(), True), StructField("c3", StringType(), True)]) df = spark.createDataFrame([(1, "2", None), (3, "4", None)], schema)
โ06-18-2021 05:09 PM
df = spark.createDataFrame(sc.emptyRDD(), schema)
Can you try this?
never-displayed
Passionate about hosting events and connecting people? Help us grow a vibrant local communityโsign up today to get started!