从pyspark.sql.snappy导入SnappyContext - ImportError:没有名为snappy的模块

Question

即使在重新安装pyspark和snappydata之后，每当我尝试从下面的代码导入pyspark.sql.snappy导入SnappyContext：

from pyspark.sql.snappy import SnappyContext
from pyspark.storagelevel import StorageLevel
SparkContext._ensure_initialized()

spark = SparkSession.builder.appName("test")  \
                        .master("local[*]") \
                        .config("spark.snappydata.connection", "localhost:1527") \
                        .getOrCreate() 

snappy = SnappySession(spark)
snappy.sql("SELECT col1, min(col2) from TABLE1")

我得到了错误：

Traceback (most recent call last):
  File "testpy.py", line 4, in <module>
    from pyspark.sql.snappy import SnappyContext
ImportError: No module named snappy

请帮帮我！

Answer 1

这是上一次发布版本中已知的问题。这已经在最新的大师中修复了。$SNAPPY_HOME/bin/pyspark引用$SNAPPY_HOME/pyspark文件夹中的python脚本。不幸的是，一些构建更改停止了在文件夹中复制SnappyData python脚本。您可以构建当前的母版，以便与火花放电一起工作。