arXivDaily arXiv每日学术速递 周一至周五更新
arXiv周末暂无论文更新,休息一下吧,周末愉快~~
arXiv 2301.07896cs.DCcs.DB
收藏

为高性能数据工程增压的分布式计算环境

Supercharging Distributed Computing Environments For High Performance Data Engineering

Niranda Perera, Kaiying Shan, Supun Kamburugamuwe, Thejaka Amila Kanewela, Chathura Widanage, Arup Sarker, Mills Staylor, Tianle Zhong, Vibhatha Abeykoon, Geoffrey Fox

摘要:

数据工程和数据科学社区已经接受了将Python和R框架用于常规应用程序的想法。在大数据革命和人工智能的推动下,这些应用程序现在对于处理TB级数据至关重要。它们很容易超过单台机器的能力,但也需要大量的开发人员时间和精力。因此,设计可扩展的嵌入式框架解决方案至关重要。已经有多种尝试来解决这个问题,最值得注意的是使用分布式计算环境开发的框架系统,例如Dask和Ray。尽管Dask/Ray分布式计算功能看起来非常有前途,但我们认为Dask数据框架/Ray数据集仍有优化的空间。在本文中,我们介绍了CylonFlow,这是一种替代的分布式框架执行方法,可以在相同的Dask/Ray基础设施上实现最先进的性能和可扩展性(从而为它们增压!)。为了实现这一点,我们集成了一个高性能的框架系统赛昂,这是最初基于一个完全不同的执行范例,到Dask和雷。我们的实验表明,在一个流水线的框架运营商,CylonFlow实现了30倍以上的分布式性能比Dask数据框架。有趣的是,由于Cylon的原生C++执行,它还实现了卓越的顺序性能。我们相信Cylon & CylonFlow的成功超越了数据工程领域,可以用于整合高性能计算和分布式计算生态系统。

英文摘要:

The data engineering and data science community has embraced the idea of using Python & R dataframes for regular applications. Driven by the big data revolution and artificial intelligence, these applications are now essential in order to process terabytes of data. They can easily exceed the capabilities of a single machine, but also demand significant developer time & effort. Therefore it is essential to design scalable dataframe solutions. There have been multiple attempts to tackle this problem, the most notable being the dataframe systems developed using distributed computing environments such as Dask and Ray. Even though Dask/Ray distributed computing features look very promising, we perceive that the Dask Dataframes/Ray Datasets still have room for optimization. In this paper, we present CylonFlow, an alternative distributed dataframe execution methodology that enables state-of-the-art performance and scalability on the same Dask/Ray infrastructure (thereby supercharging them!). To achieve this, we integrate a high performance dataframe system Cylon, which was originally based on an entirely different execution paradigm, into Dask and Ray. Our experiments show that on a pipeline of dataframe operators, CylonFlow achieves 30x more distributed performance than Dask Dataframes. Interestingly, it also enables superior sequential performance due to the native C++ execution of Cylon. We believe the success of Cylon & CylonFlow extends beyond the data engineering domain, and can be used to consolidate high performance computing and distributed computing ecosystems.

机构、总结、中文摘要均由AI分析而来,可能存在错误,请以论文正文为准。

↑