pyspark:NameError:name'spark 'が定義されていません
Pyspark Nameerror Namesparkis Not Defined
与えられた問題に示されているように、Python
デフォルトのプログラムはありませんpyspark.sql.session.SparkSession
したがって、関連するモジュールをインポートしてから変換するだけですSparkSession
。
次のようにコーディングします。
from pyspark.context import SparkContext from pyspark.sql.session import SparkSession sc = SparkContext('local') spark = SparkSession(sc) print(type(spark))
印刷されたそのタイプは正常に解決されました: