hive 两次操作时间间隔大于0.5小时(LAG)

server/2024/12/24 7:58:18/
需求

明细表A记录工人的操作记录,create_time 是操作时间,需要统计操作时间间隔大于0.5小时的次数

WITH ordered_actions AS (SELECTwaybill_no,create_time,-- 使用 LAG 函数获取上一条记录的 create_timeLAG(create_time) OVER (PARTITION BY waybill_no ORDER BY create_time) AS prev_create_timeFROMA
)
-- 计算时间间隔,并筛选出间隔大于 0.5 小时的记录
SELECTCOUNT(*) AS interval_count
FROMordered_actions
WHERE-- 计算时间差(单位为小时),并筛选出大于 0.5 小时的记录DATEDIFF(create_time, prev_create_time) * 24 > 0.5-- 排除第一个记录,因为第一个记录没有上一条记录AND prev_create_time IS NOT NULL;
需求

明细表A记录工人的操作记录,create_time 是操作时间,需要按设备统计操作时间间隔大于0.5小时的次数,相邻的操作必须是同一个设备

WITH ordered_actions AS (SELECTdevice_id,create_time,-- 使用 LAG 函数获取上一条记录的 device_id 和 create_timeLAG(device_id) OVER (ORDER BY create_time) AS prev_device_id,LAG(create_time) OVER (ORDER BY create_time) AS prev_create_timeFROMexport.tmp_zjs_08  WHERE dt='20241213' AND employee_no ='xxxx'
)
-- 计算时间间隔,并筛选出间隔大于 0.5 小时的记录
SELECTCOUNT(*) AS interval_count
FROMordered_actions
WHERE-- 检查是否为同一设备,并且时间间隔大于 0.5 小时(device_id = prev_device_id) AND(unix_timestamp(create_time) - unix_timestamp(prev_create_time)) > 1800-- 排除第一个记录,因为第一个记录没有上一条记录AND prev_create_time IS NOT NULL;


http://www.ppmy.cn/server/152713.html

相关文章

微信 SDK 更新 Sample,NCF 文档和模板更新,更多更新日志,欢迎解锁

Senparc.Weixin SDK 更新 Sample,批处理发布单个模块的 Sample 更新 Sample,引用最新版本 SDK NeuCharFramework 文档更新,提供全文检索功能 模板更新,提供菜单设置页面的父层节点置顶,解决菜单项过长,不容易编辑…

nginx学习总结(不包含安装过程)

1. nginx常见配置 http服务上支持【若干虚拟主机】。每个虚拟主机对应一个server配置项,配置项里面包含该虚拟主机相关的配置。 server{listen 80 default;server_name www.yonqin.com;index index.html index.htm index.php;root /data/www;location ~ .*\.(gif|…

Ubuntu概述

Ubuntu文件系统结构 Linux中/是一切的根目录 文件系统结构: Ubuntu磁盘管理 Ubuntu文件压缩 Ubuntu用户与用户组 文件权限变更

QT多媒体开发(三):使用QMediaPlayer播放视频

QMediaPlayer 类不仅能播放音频文件,也可以播放各种常见的视频文件,如 MP4 文件和 WMV 文件。QMediaPlayer 能对视频文件进行解码,并在某个界面组件上显示视频帧。 使用 QMediaPlayer 播放视频时,必须用函数 setVideoOutput()设置…

maven-resources-production:ratel-fast: java.lang.IndexOutOfBoundsException

Maven生产环境中遇到java.lang.IndexOutOfBoundsException的问题,尝试了重启电脑、重启IDEA等常规方法无效,最终通过直接重建工程解决了问题。 Rebuild Project 再启动OK

云起无垠荣获第八届“强网杯”高阶技术专项赛优秀奖

近日,第八届 “强网杯” 全国网络安全挑战赛线下赛于郑州高新区的网络安全科技馆赛博厅圆满落幕。云起无垠创始人兼 CEO 沈凯文博士在活动中发表了题为《安全智能体技术实践与内生安全问题思考》的精彩演讲。 沈凯文博士指出,当前数字化时代下网络安全领…

什么是事务

在数据库管理系统中,事务(Transaction)是执行一系列操作的最小工作单元,这些操作要么全部成功,要么全部失败。为了确保数据的一致性和完整性,事务被设计为具备四大特性,即原子性(Ato…

Retrofit源码分析:动态代理获取Api接口实例,解析注解生成request,线程切换

目录 一,Retrofit的基本使用 1.定义api接口 2.创建Retrofit实例 3.获取api接口实例发起请求 二,静态代理和动态代理 1,静态代理 2,动态代理 三,动态代理获取Api接口实例 四,解析接口方法注解&…