在SparkContext中未定义sc

我的Spark包是spark-2.2.0-bin-hadoop2.7。

我导出的Spark变量如下:

export SPARK_HOME=/home/harry/spark-2.2.0-bin-hadoop2.7export PATH=$SPARK_HOME/bin:$PATH

我通过以下命令打开了Spark笔记本:

pyspark

我能够从Spark加载包:

from pyspark import SparkContext, SQLContextfrom pyspark.ml.regression import LinearRegressionprint(SQLContext)

输出是

<class 'pyspark.sql.context.SQLContext'>

但我的错误是

print(sc)"sc is undefined"

请问有人能帮我解决这个问题吗…!


回答:

pysparkShell中,SparkContext已经被初始化为SparkContext(app=PySparkShell, master=local[*]),所以你只需要使用getOrCreate()来将SparkContext设置到一个变量中,如下所示:

sc = SparkContext.getOrCreate()sqlContext = SQLContext(sc)

对于在简单的本地模式下的编码目的,你可以执行以下操作:

from pyspark import SparkConf, SparkContext, SQLContextconf = SparkConf().setAppName("test").setMaster("local")sc = SparkContext(conf=conf)sqlContext = SQLContext(sc)print(sc)print(sqlContext)

Related Posts

L1-L2正则化的不同系数

我想对网络的权重同时应用L1和L2正则化。然而,我找不…

使用scikit-learn的无监督方法将列表分类成不同组别,有没有办法?

我有一系列实例,每个实例都有一份列表,代表它所遵循的不…

f1_score metric in lightgbm

我想使用自定义指标f1_score来训练一个lgb模型…

通过相关系数矩阵进行特征选择

我在测试不同的算法时,如逻辑回归、高斯朴素贝叶斯、随机…

可以将机器学习库用于流式输入和输出吗?

已关闭。此问题需要更加聚焦。目前不接受回答。 想要改进…

在TensorFlow中,queue.dequeue_up_to()方法的用途是什么?

我对这个方法感到非常困惑,特别是当我发现这个令人费解的…

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注