买专利卖专利找龙图腾，真高效！ 查专利查商标用IPTOP,全免费！专利年费监控用IP管家,真方便！

龙图腾网获悉国网信息通信产业集团有限公司申请的专利基于Spark平台的电力物联网数据检索方法、系统及设备获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN115374153B 。

龙图腾网通过国家知识产权局官网在2026-02-10发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202210934790.5，技术领域涉及：G06F16/2455；该发明授权基于Spark平台的电力物联网数据检索方法、系统及设备是由李温静;张楠;谢可;刘彩;柯华强;王金发;郭文静;陈婷;梅昕苏;陈智鹏;肖钧浩设计研发完成，并于2022-08-04向国家知识产权局提交的专利申请。

本基于Spark平台的电力物联网数据检索方法、系统及设备在说明书摘要公布了：本申请公开了一种基于Spark平台的电力物联网数据检索方法、系统及设备，主要涉及电力物联网数据检索技术领域，用以解决现有的电力物联网运行中的数据检索方案检索时间较长和消耗内存较大，存在集中地不断检索海量数据的负担。包括：S1：基于接收到的查询数据，获得数据检索语句；S2：在HIVE中创建包含检索数据的Dataframe，进而通过SparkContext实例创建一个RDD；S3：判断RDD的聚集维度是否小于Dataframe的总列数；当小于总列数时，将RDD存入HBase中；当大于或等于总列数时，通过Spark算子和BUC算法，将剪枝处理后的RDD存入HBase中；S4：将HBase中的RDD数据返回给用户。本申请通过上述方法实现了以较短的时间和较少的内存消耗成功检索到数据，摆脱了集中地不断检索海量数据的负担。

本发明授权基于Spark平台的电力物联网数据检索方法、系统及设备在权利要求书中公布了：1.一种基于Spark平台的电力物联网数据检索方法，其特征在于，所述方法包括： S1：基于接收到的查询数据，获得数据检索语句；数据检索语句包含若干子检索语句； 获取所述数据检索语句在HBase中对应的检索数据，在HIVE中创建包含所述检索数据的Dataframe，具体包括： 在确定子检索语句中指定了数据表与检索对应的表头名时，根据子检索语句，获取的第一表头数量和表头名对应的第一列数据； 在确定子检索语句中指定了数据表与全部的表头名时，根据所述数据表的列数，获取的第二表头数量和数据表对应的第二列数据； 根据所述第一表头数量和所述第二表头数量，确定用户查询数据对应的总列数和表头数据； 根据所述第一列数据和第二列数据，确定检索数据； 基于所述总列数、表头数据和检索数据，在HIVE中创建Dataframe； S2：获取所述数据检索语句在HBase中对应的检索数据，在HIVE中创建包含所述检索数据的Dataframe，进而通过SparkContext实例创建一个RDD；具体包括： 在检测到所述检索数据为集合时，调用SparkContext实例中的parallelize方法，根据检索数据创建一个RDD； 在检测到所述检索数据为本地文件或HDFS文件时，调用SparkContext实例中的textFile方法，根据检索数据创建一个RDD； S3：判断所述RDD的聚集维度是否小于Dataframe的总列数；当小于总列数时，将RDD存入HBase中；当大于或等于总列数时，通过Spark算子和BUC算法，将剪枝处理后的RDD存入HBase中；具体包括：判断RDD的聚集维度是否为1； 若为1，则使用Spark中的groupby算子统计RDD中每个维度数据出现的次数；将出现次数大于预设阈值的维度数据作为RDD数据存入Hbase；通过BUC算法将出现次数小于或等于预设阈值的维度数据剪枝并丢弃； 若不为1，则对RDD中的维度数据进行合并，并使用Spark中groupby算子和count算子对合并结果进行分组并统计次数；将出现次数大于预设阈值的合并结果作为RDD数据存入HBase； S4：将HBase中的RDD数据返回给用户。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人国网信息通信产业集团有限公司，其通讯地址为：102211 北京市昌平区未来科技城北区国网智能电网研究院内C座4层；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。

以上内容由龙图腾AI智能生成。