joinTree: A novel join-oriented multivariate operator for spatio-temporal data management in Flink

计算机科学 操作员(生物学) 连接(拓扑) 序列(生物学) 分布式计算 数据挖掘
作者
Hangxu Ji,Gang Wu,Yuhai Zhao,Shiye Wang,Guoren Wang,George Y. Yuan
出处
期刊:Geoinformatica [Springer Nature]
标识
DOI:10.1007/s10707-022-00470-5
摘要

In the era of intelligent Internet, the management and analysis of massive spatio-temporal data is one of the important links to realize intelligent applications and build smart cities, in which the interaction of multi-source data is the basis of realizing spatio-temporal data management and analysis. As an important carrier to achieve the interactive calculation of massive data, Flink provides the advanced Operator Join to facilitate user program development. In a Flink job with multi-source data connection operations, the selection of join sequences and the data communication in the repartition phase are both key factors that affect the efficiency of the job. However, Flink does not provide any optimization mechanism for the two factors, which in turn leads to low job efficiency. If the enumeration method is used to find the optimal join sequence, the result will not be obtained in polynomial time, so the optimization effect cannot be achieved. We investigate the above problems, design and implement a more advanced Operator joinTree that can support multi-source data connection in Flink, and introduce two optimization strategies into the Operator. In summary, the advantages of our work are highlighted as follows: (1) the Operator enables Flink to support multi-source data connection operation, and reduces the amount of calculation and data communication by introducing lightweight optimization strategies to improve job efficiency; (2) with the optimization strategy for join sequence, the total running time can be reduced by 29% and the data communication can be reduced by 34% compared with traditional sequential execution; (3) the optimization strategy for data repartition can further enable the job to bring 35% performance improvement, and in the average case can reduce the data communication by 43%.
最长约 10秒,即可获得该文献文件

科研通智能强力驱动
Strongly Powered by AbleSci AI
更新
大幅提高文件上传限制,最高150M (2024-4-1)

科研通是完全免费的文献互助平台,具备全网最快的应助速度,最高的求助完成率。 对每一个文献求助,科研通都将尽心尽力,给求助人一个满意的交代。
实时播报
1秒前
yoozii发布了新的文献求助10
1秒前
aniu发布了新的文献求助10
3秒前
雪白问兰应助倪莺媛采纳,获得10
3秒前
简因发布了新的文献求助30
4秒前
俏皮芹完成签到,获得积分10
4秒前
啦啦啦发布了新的文献求助10
5秒前
5秒前
科研通AI2S应助汐汐采纳,获得10
5秒前
小海完成签到 ,获得积分10
6秒前
不配.应助cj采纳,获得50
6秒前
6秒前
烟花应助正直肖采纳,获得10
7秒前
sing完成签到,获得积分10
7秒前
8秒前
深情安青应助科研通管家采纳,获得10
9秒前
汉堡包应助科研通管家采纳,获得10
9秒前
英俊的铭应助科研通管家采纳,获得10
9秒前
葡萄成熟应助科研通管家采纳,获得10
9秒前
乐乐应助科研通管家采纳,获得10
9秒前
研友_VZG7GZ应助科研通管家采纳,获得10
9秒前
小蘑菇应助科研通管家采纳,获得10
9秒前
Muttu完成签到,获得积分20
9秒前
科研通AI2S应助科研通管家采纳,获得10
10秒前
领导范儿应助WZQ采纳,获得10
10秒前
情怀应助科研通管家采纳,获得10
10秒前
10秒前
上官若男应助ROY采纳,获得10
11秒前
12秒前
陆雪发布了新的文献求助10
14秒前
一个小张啊完成签到 ,获得积分10
15秒前
雨天后完成签到,获得积分10
15秒前
siner发布了新的文献求助10
15秒前
15秒前
顾矜应助sunidea采纳,获得10
15秒前
Ijaz关注了科研通微信公众号
16秒前
英姑应助梁大海采纳,获得10
17秒前
aniu发布了新的文献求助10
17秒前
迷路老鼠完成签到,获得积分10
18秒前
19秒前
高分求助中
Sustainability in Tides Chemistry 2800
The Young builders of New china : the visit of the delegation of the WFDY to the Chinese People's Republic 1000
Rechtsphilosophie 1000
Bayesian Models of Cognition:Reverse Engineering the Mind 888
Le dégorgement réflexe des Acridiens 800
Defense against predation 800
Very-high-order BVD Schemes Using β-variable THINC Method 568
热门求助领域 (近24小时)
化学 医学 生物 材料科学 工程类 有机化学 生物化学 物理 内科学 纳米技术 计算机科学 化学工程 复合材料 基因 遗传学 催化作用 物理化学 免疫学 量子力学 细胞生物学
热门帖子
关注 科研通微信公众号,转发送积分 3136127
求助须知:如何正确求助?哪些是违规求助? 2787029
关于积分的说明 7780244
捐赠科研通 2443154
什么是DOI,文献DOI怎么找? 1298899
科研通“疑难数据库(出版商)”最低求助积分说明 625294
版权声明 600870