Pyspark 中 SparkSession 的导入错误

Question

我安装了 Spark 2.0 版本。我正在使用 Python 2.7 上的 Pyspark。我似乎创建 SparkContext 没有困难，但由于某种原因我无法导入 SparkSession。有谁知道我做错了什么？

import pyspark
import pyspark.sql
from pyspark.sql import SparkSession
Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
 ImportError: cannot import name SparkSession

Answer 1

奇怪的是，这在不同的目录下运行得很好。从该路径运行文件不会导致错误！

/用户/.../spark-2.1.0-bin-hadoop2.7/python/