pyspark と snappydata を再インストールした後でも、以下のコードから pyspark.sql.snappy import 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
助けてください!