DatabricksでSparkバージョン2.1を使用しています。定数値を取る必要があるwamp
という名前の列を追加したいという名前のデータフレームがありregion
ますNE
。ただし、NameError: name 'lit' is not defined
次のコマンドを実行するとエラーが発生します。
wamp = wamp.withColumn('region', lit('NE'))
私は何が間違っているのですか?
インポートする必要があります lit
どちらか
from pyspark.sql.functions import *
ようになりますlit
利用可能
またはのようなもの
import pyspark.sql.functions as sf
wamp = wamp.withColumn('region', sf.lit('NE'))
この記事はインターネットから収集されたものであり、転載の際にはソースを示してください。
侵害の場合は、連絡してください[email protected]
コメントを追加