擅长:python、mysql、java
<p>如果您使用python,则需要初始化spark会话</p>
<pre><code>import os
import sys
spark_home = os.environ.get('SPARK_HOME', None)
sys.path.insert(0, os.path.join(spark_home, 'python'))
sys.path.insert(0, os.path.join(spark_home, 'python/lib/py4j-0.10.4-src.zip'))
execfile(os.path.join(spark_home, 'python/pyspark/shell.py'))
</code></pre>
<p>以上是我的代码,您可能需要在spark安装中找到相应的库并替换上面的路径。在</p>
<p>如果你幸运的话,你会看到这样的东西</p>
^{pr2}$