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

修改测试文件

parent 93ca3606
...@@ -32,7 +32,7 @@ def test(): ...@@ -32,7 +32,7 @@ def test():
# 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 user_id from online.tl_hdfs_maidian_view
where partition_date = '20190412' limit 10 ''').show(6) where partition_date = '20190412' limit 10 ''').show(6)
......
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