ICode9

精准搜索请尝试: 精确搜索
首页 > 其他分享> 文章详细

道路卡口摄像头的异常状态统计

2022-09-15 10:34:16  阅读:210  来源: 互联网

标签:monitorId 卡口 val cameras session 道路 id 摄像头


package camera

import org.apache.spark.SparkConf
import org.apache.spark.sql.SparkSession

// 摄像异常状态的功能代码
object CameraAbnormality {
  def main(args: Array[String]): Unit = {
    val conf = new SparkConf().setAppName("camera").setMaster("local[*]")
    val session = SparkSession.builder().config(conf).getOrCreate()

    val map = Map[String, String]("mode" -> "FAILFAST", "inferSchema" -> "true")

    val frame1 = session.read.options(map).csv("hdfs://HadoopCluster/cameras.csv")
    // 卡口摄像头数据
    // 卡口id: 区域id-街道id-卡口编号
    // 摄像头id: 1-8
    val cameras = frame1.toDF("monitorId", "cameraId")

    val frame2 = session.read.options(map).csv("hdfs://HadoopCluster/project/20220913/*")
    // 车流量信息
    // 车辆通过时间  卡口编号  摄像头编号  通过车辆车牌  某个摄像头拍摄时间 单位:秒  通过卡口的速度  道路id  区域id
    // 2022-09-13,  5-23-63,        3,      晋KIFWNQ,      2022-09-13 15:47:47,        17,        23,      5
    // todayDate  monitorId  camera_id    chepai           actionTime             speed      roadId  areaId
    val flow = frame2.toDF("todayDate", "monitorId", "cameraId", "chepai", "actionTime", "speed", "roadId", "areaId")
    cameras.createTempView("cameras")
    flow.createTempView("flow")

//    cameras.show(10)
//    flow.show(10)

    val frame = session.sql(
      "select a.monitorId, a.cameraId " +
        "from cameras as a " +
        "left join flow as b " +
        "on a.monitorId = b.monitorId and a.cameraId = b.cameraId " +
        "where b.chepai is null " +
        "order by a.monitorId")
    frame.show(200)

    session.stop()
  }
}

标签:monitorId,卡口,val,cameras,session,道路,id,摄像头
来源: https://www.cnblogs.com/jsqup/p/16695635.html

本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享;
2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关;
3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关;
4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除;
5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有