一种基于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文件可下载
