修改测试文件

tensnsorflow/test.py

@@ -30,10 +30,7 @@ def test():
 
         from pyspark.sql import SparkSession
 
-        spark = SparkSession \
-            .builder \
-            .appName("BinarizerExample") \
-            .getOrCreate()
+        spark = SparkSession.builder.appName("BinarizerExample").enableHiveSupport().getOrCreate()
         spark.sql("SET mapreduce.job.queuename=data")
         spark.sql("SET mapred.input.dir.recursive=true")
         spark.sql("SET hive.mapred.supports.subdirectories=true")
@@ -42,7 +39,7 @@ def test():
         # hive_context.sql("SET mapred.input.dir.recursive=true")
         # hive_context.sql("SET hive.mapred.supports.subdirectories=true")
         sql = "select user_id from online.tl_hdfs_maidian_view where partition_date = '20190412' limit 10"
-        hive_context.sql(sql).show(6)
+        spark.sql(sql).show(6)
 
 
 # def esmm_pre():