Commit bf5569f2 authored by 张彦钊's avatar 张彦钊

修改测试文件

parent f2077b7d
......@@ -31,9 +31,8 @@ def test():
# hive_context.sql("SET mapreduce.job.queuename=data")
# hive_context.sql("SET mapred.input.dir.recursive=true")
# hive_context.sql("SET hive.mapred.supports.subdirectories=true")
hive_context.sql(''' select user_id from online.tl_hdfs_maidian_view
where partition_date = '20190412' limit 10 ''').show(6)
sql = "select user_id from online.tl_hdfs_maidian_view where partition_date = '20190412' limit 10"
hive_context.sql(sql).show(6)
# 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