未定义Pyspark结构类型

Question

我试图构造一个用于数据库测试的模式，而StructType显然由于某种原因无法工作。我在跟踪一个tut，它不导入任何额外的模块。

<type 'exceptions.NameError'>, NameError("name 'StructType' is not defined",), <traceback object at 0x2b555f0>)

我在spark 1.4.0和Ubuntu12上，如果这和问题有关的话。我该如何解决这个问题？提前谢谢你。

Answer 1

您导入了StructType吗？如果没有

from pyspark.sql.types import StructType

应该能解决问题。