在线分析处理（Online Analytical Processing，OLAP）技术是大数据技术中快速解决多维分析问题的方法之一。由于OLAP需要快速读取大量数据，因此它对数据的读取吞吐量和计算效率有很高的要求。目前，基于大数据的OLAP技术一般从面向读的存储优化、预计算、支持灵活分析等方面不断提高，近几年出现了很多令人激动的产品。

OLAP技术让用户能够从多个角度交互地分析多维数据，从中发现规律，用来做决策支持。在分析过程中，用户需要获取和处理历史数据（一段时期内），有时也需要获取和处理实时数据，此时查询吞吐量和相应时间是关键性能指标。

1、OLAP分析操作

OLAP分析一般需要设计数据立方体，立方体由分析的维度（dimension）、层级（level）和指标（metric）来定义，支持上卷（roll-up）、钻取（drill-down）、切片（slicing）和切块（dicing）等分析操作。

• 上卷：将数据按一个或多个维度向更高层级聚合，例如基于县级销售额统计市级销售额。

• 钻取：上卷的反向操作。

• 切片和切块：从OLAP多维数据集中按选择维度的特定数值选取出一组特定的数据，例如一季度的所有数据。

• 切块：从OLAP多维数据集中按选择维度的特定数值区间选取出一组特定的数据，例如2月到5月的所有数据。

2、与OLTP的区别

与OLAP相对的是OLTP。OLTP的全称是联机事务处理（Online Transaction Processing），是传统关系型数据库的主要应用。OLTP的特点是实现插入、更新、删除等事务的在线处理，但系统需要保证事务的完整性，满足ACID原则。在OLTP中，事务的吞吐量是关键性能指标，以每秒事务数来衡量效率。

由于严格的约束限制，支持OLTP的数据系统通常无法满足OLAP大规模数据读取与处理的需求，二者对数据读取的吞吐量要求相差不止一个量级，因此OLAP系统的技术选型一般与OLTP不同，数据的组织方式也不同。

随着DT时代的到来，越来越多的业务需求要求大数据系统既能处理历史数据，又能进行实时计算，同时越来越要求运营的时效性，以便即时评估运营活动效果，即时调整策略。针对实时大数据统计分析系统，有两种架构设计路线：Lambda和Kappa。

• Lambda架构包含三层：批处理层（Batch Layer）、速度层（Speed Layer）和服务层（Serving Layer）。批处理层对历史数据进行预处理，速度层处理新增实时数据，服务层实现上述两层处理结果的融合，将其合并为统一视图，为用户提供全时域数据分析查询。每层可以分别选择合适的大数据组件来构建系统，比如用Spark构建批处理层、用Flink构建速度层。

• Kappa架构在Lambda架构的基础上去掉了批处理层，对速度层进行了改进，使其既能够支持实时数据处理，又能够支持历史数据处理。Kappa架构只有实时层和服务层。Kappa架构通常是将流式框架中的数据通道替换成消息队列（如Kafka），可以设定一定的保留期限，如分析逻辑改变，重新从消息队列消费数据处理即可。

实时OLAP系统的两种架构模型对比如图1所示。

▲图1　实时OLAP的两种架构模型对比

两种架构模型的优缺点对比如下：

• Lambda架构具有很好的灵活性、可扩展性和容错性，但分别处理历史数据与实时数据时常常出现处理逻辑或计算结果不一致的情况，另外系统建设和维护复杂。

• Kappa架构只需维护一套代码，可以做到数据处理逻辑与计算结果的一致性。Kappa架构并不是Lambda架构的替代品，二者的应用场景不同。Kappa架构由于全部采用流式处理，数据处理吞吐量不如Lambda架构，处理资源成本也较高。

按照数据模型可将OLAP相关技术分为MOLAP、ROLAP和HOLAP 3种类型：

• MOLAP表示Multidimensional OLAP（多维型OLAP），一般是基于预计算生成多维数据立方体；

• ROLAP是指Relational OLAP（关系型OLAP），一般不进行预计算，直接关联事实表与维度表进行查询；

• HOLAP是指Hybrid OLAP（混合型OLAP），是混合利用MOLAP和ROLAP方法，综合二者的优缺点。

按照实现的技术方法可将OLAP相关技术分为MPP架构、预计算和搜索引擎三类。

• MPP架构：最常见的OLAP引擎架构，MPP架构具有完全的可伸缩性、高可用、高性能、高性价比等优势。此类又分两种，一种是MPP数据库，它基于关系数据模型建立数据仓库的主要技术选型，是大数据场景ROLAP的实现方法，典型的产品是Greenplum、ClickHouse；另一种是MPP分析引擎，它仅基于MPP架构实现计算功能，数据存储则依赖于其他存储系统（如HDFS），典型的产品有Presto、Impala。

• 预计算：基于定义的数据立方体，在明细表上进行预计算，在多维分析时仅执行查询操作，是实现MOLAP的典型方法。优点是查询时如果命中预计算结果则几乎没有延迟，适合对超大原始数据集的分析，可实现秒级响应；缺点是预计算量大、不灵活、支持维度有限（否则存在维度灾难）、查询延迟时间不稳定（取决于是否命中预计算结果）。典型的产品如Apache Kylin，也有产品通过控制预计算的程度以避免预计算量太大，如Druid。

• 搜索引擎：在入库时将数据转换为倒排索引，在搜索类查询上能做到亚秒级响应，但是对于扫描聚合为主的查询，随着处理数据量的增加，响应时间也会退化到分钟级。另外，搜索引擎对存储消耗很大。典型的产品如Elasticsearch、Solr。

三种技术方法的优缺点及适用场景对比如表1所示。

▼表1　三种技术方法的优缺点及适用场景对比

针对这三种技术实现方法，该如何做技术选型呢？OLAP技术需要考虑系统的数据量、性能和灵活性三个方面，但是目前还没有一种方法能同时在这三个方面做到完美，在设计时需要在这三个方面之间做出取舍。比如MPP架构，它有很好的数据量和灵活性的支持，但是它的性能无法保证，随着计算量和复杂度的增加，响应时间可能从秒级变为分钟级甚至小时级。而预计算系统和搜索引擎技术方法则是通过牺牲灵活性来换取高性能。另外，还要考虑是否需要查询明细数据等辅助需求。

本节介绍两个Hadoop体系兼容的OLAP产品，一个是基于MPP架构的OLAP引擎—

Impala，一个是基于预计算方法的OLAP引擎—Kylin。

1、Impala

Impala属于SQL on Hadoop的开源MPP分析引擎，可在Hadoop集群上运行。它由Cloudera公司主导开发，作为Hive的高性能替代品，用于大数据实时查询分析。Impala提高了Apache Hadoop的SQL查询性能，同时保留了熟悉的Hive用户体验，采用SQL语法（Hive SQL），使得Hive的用户可以顺畅地迁移到Impala上。Impala采用与基础数据存储引擎分离的设计，使用HDFS和HBase作为数据存储，并从Hive获取元数据，这是它与传统关系型数据库系统的主要区别。传统关系数据的查询引擎与存储引擎是紧密耦合的。

为了避免延迟，Impala避开了MapReduce，通过专门实现的分布式查询引擎直接访问数据，比Hive快几个数量级。

Impala的优点如下所示。

• 在数据所在节点对数据进行本地处理，避免网络传输瓶颈；

• 支持线性扩展；

• 与Hadoop体系使用相同的基础设施，直接利用Hadoop体系的元数据、安全和资源管理；

• 直接读取Hadoop系统中的数据，无须进行高成本的数据格式转换；

• 所有数据均可立即查询。

Impala由三个服务组成：Impala主进程（Impala daemon）、StateStore进程和Catalog进程。

• Impala主进程：负责接收客户端的查询请求，协调请求在集群中的执行，并负责执行一个查询片段。Impala主进程包含三个子模块：Query Planner、Query Coordinator、Query Exec Engine。每台服务器上会运行一个Impala主进程（与HDFS的DataNode在同一个主机上运行），所有的Impala主进程都是对等的。Impala主程序与StateStore进程保持持续通信，以确认哪些节点的主进程是健康的并可以接收新工作。

• StateStore进程：充当Impala的Catalog储存库和元数据访问网关，会检查集群中所有Impala主进程的运行状况，并将发现结果不断传递给每个主进程。

• Catalog进程：将Impala SQL语句的元数据更改传递到集群的所有Impala主进程中。

Impala架构示意图如图2所示。

▲图2　Impala架构

2、Kylin

Apache Kylin是一个开源的分布式分析引擎，提供Hadoop、Spark之上的SQL查询接口及多维分析能力以支持超大规模数据，最初由eBay开发并贡献至开源社区。

Kylin通过三步支持查询。

• 模型定义：定义数据集的星形或雪花形模型。

• 预计算：通过数据立方体计算引擎（Cube Build Engine）组件对明细数据进行离线计算，生成用于查询的数据立方体（OLAP Cube），并将Cube数据存储于HBase中。

• 在线查询：在线查询时通过标准SQL或RESTful API，查询引擎（Query Engine）首先对预计算的数据立方体进行查询，如果命中缓存，则可以实现秒级响应，如果没有命中缓存，则进行实时计算，延迟会比较高。

Kylin原理示意图如图3所示。

图3　Kylin原理

Apache Kylin的特性如下所示。

• 能够处理百亿规模数据，可扩展，预计算生成数据立方体，在线查询亚秒级响应。

• 兼容Hadoop体系。

• 提供标准SQL，支持大部分查询功能。

• 能与BI工具的无缝整合，如Tableau。

本文摘编于《数据应用工程：方法论与实践》，经出版方授权发布。（书号：9787111704096）转载请保留文章出处。