“StructType”对象没有属性“toDDL”

Question

我正在使用 Spark 2.4.3 和 python 3.6.10 运行此脚本

columns = ["language","users_count"]
data = [("Java", "20000"), ("Python", "100000"), ("Scala", "3000")]
spark = SparkSession.builder.appName('SparkByExamples.com').getOrCreate()
rdd = spark.sparkContext.parallelize(data)
df = rdd.toDF()
print(df.schema.toDDL)

AttributeError：“StructType”对象没有属性“toDDL”

java文档提到该函数从spark 2.4.0开始可用，但python文档toDDL中没有该函数。

还有其他方法可以从 python 使用这个 java 函数吗？

Answer 1

toDDL您可以在 Java dataframe 对象上调用该方法：

df._jdf.schema().toDDL()