乘风原创程序

  • 使用SQL实现车流量的计算的示例代码
  • 2022/3/1 11:18:27
  • 卡口转换率

    将数据导入hive,通过sparksql编写sql,实现不同业务的数据计算实现,主要讲述车辆卡口转换率,卡口转化率:主要计算不同卡口下车辆之间的流向,求出之间的转换率。

    在这里插入图片描述

    1、查出每个地区下每个路段下的车流量

    此结果做为表1,方便后面错位连接使用

    在这里插入图片描述

    2、通过错位连接获取每辆车的行车记录

    通过表1的结果,与自身进行错位链接,并以车牌为分区,拼接经过卡口的过程

    在这里插入图片描述

    获取到每辆车的一个行车记录,经过的卡口

    3、获取行车过程中的车辆数

    获取卡口1~卡口2,…等的车辆数有哪些,即拿上面的行车记录字段进行分区在进行统计

    在这里插入图片描述

    4、获取每个卡口的总车辆数

    获取每个卡口最初的车辆数,方便后面拿行车轨迹车辆数/总车辆数,得出卡口之间的转换率

    在这里插入图片描述

    5、求出卡口之间的转换率

    在这里插入图片描述

     到此这篇关于使用sql实现车流量的计算的示例代码的文章就介绍到这了,更多相关sql 车流量内容请搜索本教程网以前的文章或继续浏览下面的相关文章希望大家以后多多支持本教程网!