一种基于Apache Flink的分布式流体动力学计算方...
实质审查的生效
摘要
本发明公开了一种基于ApacheFlink的分布式流体动力学计算方法,包括如下步骤:数据采集:接收特定流域所产生的流体数据,使用分布式收集实时采集的流体数据;数据清洗:使用Flink平台的map算子拆分功能,将采集到的流体数据一行一行转换出来,使用Flink平台的flatmap算子拆分功能,将每条流体数据记录由一行转换成多行,使用Flink平台的keyby算子分区功能,将每条流体数据记录按照速度值字段进行数据分区,将相同的速度值放到同一个分区。本发明通过使用使用flink框架,数据实时性处理很强,不会产生数据的延迟,保证数据的一致性,数据的吞吐量很强,即数据可以频繁的写入到flink当中且不会丢失。
基本信息
专利标题 :
一种基于Apache Flink的分布式流体动力学计算方法
专利标题(英):
暂无
公开(公告)号 :
CN114372429A
申请号 :
CN202210035302.7
公开(公告)日 :
2022-04-19
申请日 :
2022-01-13
授权号 :
暂无
授权日 :
暂无
发明人 :
任南琪王爱杰王旭路璐冯骁驰
申请人 :
澜途集思生态科技集团有限公司
申请人地址 :
北京市海淀区蓝靛厂东路2号院金源时代商务中心2号楼A座6D
代理机构 :
北京市京师律师事务所
代理人 :
黄熊
优先权 :
CN202210035302.7
主分类号 :
G06F30/28
IPC分类号 :
G06F30/28 G06F113/08 G06F119/14
IPC结构图谱
G
G部——物理
G06
计算;推算或计数
G06F
电数字数据处理
G06F30/28
使用流体动力学,例如使用纳维-斯托克斯方程或计算流体力学
法律状态
2022-05-06 :
实质审查的生效
IPC(主分类) : G06F 30/28
申请日 : 20220113
申请日 : 20220113
2022-04-19 :
公开
注:本法律状态信息仅供参考,即时准确的法律状态信息须到国家知识产权局办理专利登记簿副本。
文件下载
暂无PDF文件可下载