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

用于分布式数据处理的内存索引缓存

In-Memory Indexed Caching for Distributed Data Processing

Alexandru Uta, Bogdan Ghit, Ankur Dave, Jan Rellermeyer, Peter Boncz

摘要:

强大的抽象,如嵌入式框架,其效率仅与其底层运行时系统一样高。事实上的分布式数据处理框架Apache Spark不太适合现代基于云的数据科学工作负载,因为它的假设已经过时:使用粗粒度转换分析静态数据集。在本文中,我们介绍了索引数据帧,内存中的高速缓存,支持一个抽象的结构,它结合了索引功能,以支持快速查找和连接操作。此外,它支持多版本并发控制的追加。我们将Indexed DataFrame实现为一个轻量级的独立库,可以以最小的努力集成到现有的Spark程序中。我们使用Apache Spark和Databricks SDK分析了索引数据帧在集群和云部署中的性能,并使用真实的数据集和基准测试。在我们的评估中,我们表明,索引的DataFrame显着加快查询执行相比,非索引的DataFrame,产生适度的内存开销。

英文摘要:

Powerful abstractions such as dataframes are only as efficient as their underlying runtime system. The de-facto distributed data processing framework, Apache Spark, is poorly suited for the modern cloud-based data-science workloads due to its outdated assumptions: static datasets analyzed using coarse-grained transformations. In this paper, we introduce the Indexed DataFrame, an in-memory cache that supports a dataframe abstraction which incorporates indexing capabilities to support fast lookup and join operations. Moreover, it supports appends with multi-version concurrency control. We implement the Indexed DataFrame as a lightweight, standalone library which can be integrated with minimum effort in existing Spark programs. We analyze the performance of the Indexed DataFrame in cluster and cloud deployments with real-world datasets and benchmarks using both Apache Spark and Databricks Runtime. In our evaluation, we show that the Indexed DataFrame significantly speeds-up query execution when compared to a non-indexed dataframe, incurring modest memory overhead.

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

↑