以下是我的代码,我遇到了下面的错误,请帮忙解决:
from delta.tables import *
ModuleNotFoundError: No module named 'delta.tables'
INFO SparkContext: Invoking stop() from shutdown hook
这里是代码: '''
from pyspark.sql import *
if __name__ == "__main__":
spark = SparkSession \
.builder \
.appName("DeltaLake") \
.config("spark.jars", "delta-core_2.12-0.7.0") \
.config("spark.sql.extensions", "io.delta.sql.DeltaSparkSessionExtension") \
.config("spark.sql.catalog.spark_catalog", "org.apache.spark.sql.delta.catalog.DeltaCatalog") \
.getOrCreate()
from delta.tables import *
data = spark.range(0, 5)
data.printSchema()
一个在线搜索建议验证scala版本与delta core jar版本相匹配,以下是scala和jar版本:
"delta-core_2.12-0.7.0"
"使用Scala版本2.12.10,Java HotSpot(TM) 64-Bit Server VM, 1.8.0_221"
tables
实际上存在于 delta Python 包中。 - Bram