【发布时间】:2017-04-11 10:14:37
【问题描述】:
【问题讨论】:
-
您好,如果您的回答令您满意,请在箭头上打勾并可能点赞。
标签: hive pyspark pyspark-sql
【问题讨论】:
标签: hive pyspark pyspark-sql
使用 SparkSession 代替 SQLContext。这样做:
sqlContext = SparkSession.builder.master("local[*]").appName("appName").
config("spark.sql.warehouse.dir", "./spark-warehouse").getOrCreate()
您的其余代码应该可以正常工作。
您可以从 sqlContext 调整变量名称以反映所持有的引用。
【讨论】: