“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' object has no attribute 'toDDL'

The java documentation提到toDDL函数可从spark 2.4.0获得，它不在the python documentation中

有没有其他方法可以使用python中的这个java函数

Answer 1

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

df._jdf.schema().toDDL()