Commit 93ca3606 authored by 张彦钊's avatar 张彦钊

修改测试文件

parent 490f9f00
...@@ -28,13 +28,12 @@ def test(): ...@@ -28,13 +28,12 @@ def test():
hive_context = HiveContext(sc) hive_context = HiveContext(sc)
hive_context.sql("SET mapreduce.job.queuename=data") # hive_context.sql("SET mapreduce.job.queuename=data")
hive_context.sql("SET mapred.input.dir.recursive=true") # hive_context.sql("SET mapred.input.dir.recursive=true")
hive_context.sql("SET hive.mapred.supports.subdirectories=true") # hive_context.sql("SET hive.mapred.supports.subdirectories=true")
hive_context.sql(''' select device["device_type"] from online.tl_hdfs_maidian_view hive_context.sql(''' select device["device_type"] from online.tl_hdfs_maidian_view
where partition_date = '20181012' and action = "page_view" where partition_date = '20190412' limit 10 ''').show(6)
and params["page_name"] = "diary_detail" and params["referrer"] = "home" limit 10 ''').show(6)
# def esmm_pre(): # def esmm_pre():
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment