誤差”的名字IntegerType沒有定義”在試圖轉換IntegerType DF列

[BingQian]

initialDF .withColumn (“OriginalCol”, initialDF.OriginalCol.cast (IntegerType))

或

initialDF .withColumn (“OriginalCol”, initialDF.OriginalCol.cast (IntegerType ()))

然而,總是失敗,這個錯誤:

NameError:名字“IntegerType”沒有定義

任何幫助都是感激。

[KristoRaun · Accepted solution]

我假設你是使用Python。

為了使用IntegerType,首先必須導入以下聲明:

從pyspark.sql。類型進口IntegerType

如果你計劃有各種各樣的轉換,將意義導入所有類型。可以如下:

從pyspark.sql。導入類型*

為進一步的參考,你可以檢查火花文檔:

https://spark.apache.org/docs/latest/sql-reference.html

[BingQian]

謝謝@Kristo Raun !