首页 > 其他分享 >HIVE如何获取当前日期的前两个工作日及后三个工作日

HIVE如何获取当前日期的前两个工作日及后三个工作日

时间:2022-12-22 14:36:10浏览次数:47  
标签:lg cur 05 HIVE workday 及后 2021 date 工作日

 1 create temporary table if not exists tmp as
 2 select 
 3     cur_date,
 4     if_workday,
 5     sum(if_workday) over (order by cur_date asc) lg
 6 FROM
 7 (
 8      select
 9         cur_date,
10         case when is_workday=1 then 1 else 0 end as if_workday
11     from crisps_dim.dim_com_date_info f1
12 ) t
13 order by cur_date asc;
14 
15 select
16     a.*,
17     b.cur_date
18 from tmp  a
19 left join tmp b on if(a.if_workday=1,(a.lg-2),(a.lg-1)) = b.lg and b.if_workday = 1;
cur_date if_workday lg cur_date
2021-05-14 1 341 2021-05-12
2021-05-13 1 340 2021-05-11
2021-05-12 1 339 2021-05-10
2021-05-11 1 338 2021-05-08
2021-05-10 1 337 2021-05-07
 1 set hive.execution.engine = spark;
 2 create temporary table if not exists tmp as
 3 select
 4     cur_date,
 5     if_workday,
 6     sum(if_workday) over (order by cur_date asc) lg
 7 FROM
 8 (
 9      select
10         cur_date,
11         case when is_workday=1 then 1 else 0 end as if_workday
12     from crisps_dim.dim_com_date_info f1
13 ) t
14 order by cur_date asc;
15 
16 select
17     a.*,
18     b.cur_date
19 from tmp  a
20 left join tmp b on (a.lg + 2) = b.lg and b.if_workday = 1;
cur_date if_workday lg cur_date
2021-05-14 1 341 2021-05-18
2021-05-13 1 340 2021-05-17
2021-05-12 1 339 2021-05-14
2021-05-11 1 338 2021-05-13
2021-05-10 1 337 2021-05-12

 

标签:lg,cur,05,HIVE,workday,及后,2021,date,工作日
From: https://www.cnblogs.com/ererciwan/p/16998587.html

相关文章

  • 大数据--pyspark远程连接hive
    上一篇文章介绍了python连接hive的过程,通过地址+端口号访问到hive并对hive中的数据进行操作,这一篇文章介绍一下怎么通过windows本地pyspark+本地部署好的spark+远程虚拟机......
  • 大数据--python远程连接Hive
    步骤:启动metastore启动hiveserver2使用beeline进行连接测试,查看地址等是否能够成功连接(确认无误可以跳过)使用python连接hive(粗暴的文件配置以及完整操作见文末)一.启动hives......
  • Flink使用TableAPi方式读取和写入Hive
    以下是一个简单的参考实例,用来验证通过FlinkSQL来跑批方式清洗Hive数据可行的。(1)验证了Hive中org.openx.data.jsonserde.JsonSerDe格式的表是可以直接读取数据出来的(2)通......
  • hive执行大SQL的时候hive.server2.thrift.max.worker.threads if applicable.
    UnexpectedendoffilewhenreadingfromHS2server.Therootcausemightbetoomanyconcurrentconnections.Pleaseasktheadministratortocheckthenumbero......
  • hive初始化报错Exception in thread " main" java.lang.classNotFoundException: org.
    问题:hive初始化报错 解决方法:https://blog.csdn.net/weixin_51946865/article/details/128020686?spm=1001.2014.3001.5502原因:在我的hadoop配置文件hadoop-env.sh(......
  • hive配置Tez引擎,并安装Tez-ui
    目录一、下载Tez1、下载apache-tez-0.9.2-bin.tar.gz包二、hive配置tez引擎1、解压apache-tez-0.9.2-bin.tar.gz2、进入tez目录,上传tez目录下的share/tez.tar.gz到......
  • 【转载】Percona-Toolkit 之 pt-archiver 总结
    概述pt-archiver -ArchiverowsfromaMySQLtableintoanothertableorafile.pt-archiver nibblesrecordsfromaMySQLtable.The --source and --dest......
  • 【分布式存储数据恢复】hbase和hive数据库数据恢复案例
    分布式存储数据恢复环境:16台物理服务器,每台物理服务器上有数台虚拟机;虚拟机上配置分布式,上层部署hbase数据库和hive数据库。分布式存储故障&分析:误删除数据库底层文件,数......
  • Hive: 一、优化篇
    1.执行参数优化--分区SEThive.exec.dynamic.partition=true;SEThive.exec.dynamic.partition.mode=nonstrict;sethive.exec.max.dynamic.partitions.pernode=10000;......
  • Hive与HBase的整合
    开场白:Hive与HBase的整合功能的实现是利用两者本身对外的API接口互相进行通信,相互通信主要是依靠hive_hbase-handler.jar工具类(​​HiveStorageHandlers​​),大致意思......