Pyspark的StructType未定义。

Question

我正在尝试为数据库测试构建模式，但StructType似乎因某种原因无法正常工作。我正在按照教程进行操作，并且没有导入任何额外的模块。

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

我使用的是 Spark 1.4.0 和 Ubuntu 12，不知道这是否与问题有关。请问我该如何解决这个问题？提前感谢您的回答。

- Joseph Seung Jae Dollar

Answer 1

你是否已经导入了StructType？如果没有，请先导入。

from pyspark.sql.types import StructType

应该解决这个问题。

- zero323

Answer 2

from pyspark.sql.types import StructType

这样可以解决问题，但接下来您可能会遇到NameError：name 'IntegerType'未定义或NameError：name 'StringType'未定义的错误..

为了避免所有这些问题，只需执行以下操作：

from pyspark.sql.types import *

或者逐个导入您需要的所有类型：

from pyspark.sql.types import StructType, IntegerType, StringType

所有类型：Apache Spark 数据类型

- Ani Menon